diff --git a/indexing-service/src/main/java/com/metamx/druid/indexing/coordinator/RemoteTaskRunner.java b/indexing-service/src/main/java/com/metamx/druid/indexing/coordinator/RemoteTaskRunner.java index a823e0ce3ad5567c44d34fa244d8076f9ad9ab77..32c5bed1dcdc8ac5b16dc27a61d55f61ab3ddb1f 100644 --- a/indexing-service/src/main/java/com/metamx/druid/indexing/coordinator/RemoteTaskRunner.java +++ b/indexing-service/src/main/java/com/metamx/druid/indexing/coordinator/RemoteTaskRunner.java @@ -691,7 +691,7 @@ public class RemoteTaskRunner implements TaskRunner, TaskLogProvider { int retVal = -Ints.compare(zkWorker.getCurrCapacityUsed(), zkWorker2.getCurrCapacityUsed()); if (retVal == 0) { - retVal = zkWorker.getWorker().getHost().compareTo(zkWorker.getWorker().getHost()); + retVal = zkWorker.getWorker().getHost().compareTo(zkWorker2.getWorker().getHost()); } return retVal;