diff --git a/merger/src/main/java/com/metamx/druid/merger/coordinator/ZkWorker.java b/merger/src/main/java/com/metamx/druid/merger/coordinator/ZkWorker.java index ff5ad95bf04..d500fe7c0a0 100644 --- a/merger/src/main/java/com/metamx/druid/merger/coordinator/ZkWorker.java +++ b/merger/src/main/java/com/metamx/druid/merger/coordinator/ZkWorker.java @@ -112,8 +112,6 @@ public class ZkWorker implements Closeable { return "ZkWorker{" + "worker=" + worker + - ", statusCache=" + statusCache + - ", cacheConverter=" + cacheConverter + ", lastCompletedTaskTime=" + lastCompletedTaskTime + '}'; } diff --git a/merger/src/main/java/com/metamx/druid/merger/coordinator/scaling/ResourceManagementScheduler.java b/merger/src/main/java/com/metamx/druid/merger/coordinator/scaling/ResourceManagementScheduler.java index 2473e9d6e41..b3ea474cc0c 100644 --- a/merger/src/main/java/com/metamx/druid/merger/coordinator/scaling/ResourceManagementScheduler.java +++ b/merger/src/main/java/com/metamx/druid/merger/coordinator/scaling/ResourceManagementScheduler.java @@ -81,7 +81,6 @@ public class ResourceManagementScheduler @Override public void run() { - log.info("Running resource management strategy"); resourceManagementStrategy.doProvision( taskRunner.getPendingTasks(), taskRunner.getWorkers() diff --git a/merger/src/main/java/com/metamx/druid/merger/worker/Worker.java b/merger/src/main/java/com/metamx/druid/merger/worker/Worker.java index 6b349de38f7..e8eaac824b3 100644 --- a/merger/src/main/java/com/metamx/druid/merger/worker/Worker.java +++ b/merger/src/main/java/com/metamx/druid/merger/worker/Worker.java @@ -84,4 +84,15 @@ public class Worker { return version; } + + @Override + public String toString() + { + return "Worker{" + + "host='" + host + '\'' + + ", ip='" + ip + '\'' + + ", capacity=" + capacity + + ", version='" + version + '\'' + + '}'; + } }