From fab7caafffa8f15da53c5e1252d2fb501c44a27f Mon Sep 17 00:00:00 2001 From: fjy Date: Tue, 30 Sep 2014 12:32:14 -0700 Subject: [PATCH] final code reviews --- .../main/java/io/druid/indexing/overlord/ImmutableZkWorker.java | 2 +- .../src/main/java/io/druid/indexing/worker/Worker.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/indexing-service/src/main/java/io/druid/indexing/overlord/ImmutableZkWorker.java b/indexing-service/src/main/java/io/druid/indexing/overlord/ImmutableZkWorker.java index 51d05d222d0..f657b6a2435 100644 --- a/indexing-service/src/main/java/io/druid/indexing/overlord/ImmutableZkWorker.java +++ b/indexing-service/src/main/java/io/druid/indexing/overlord/ImmutableZkWorker.java @@ -66,4 +66,4 @@ public class ImmutableZkWorker return (worker.getCapacity() - getCurrCapacityUsed() >= task.getTaskResource().getRequiredCapacity() && !getAvailabilityGroups().contains(task.getTaskResource().getAvailabilityGroup())); } -} \ No newline at end of file +} diff --git a/indexing-service/src/main/java/io/druid/indexing/worker/Worker.java b/indexing-service/src/main/java/io/druid/indexing/worker/Worker.java index c706122e649..ac41aa7292a 100644 --- a/indexing-service/src/main/java/io/druid/indexing/worker/Worker.java +++ b/indexing-service/src/main/java/io/druid/indexing/worker/Worker.java @@ -76,7 +76,7 @@ public class Worker return "Worker{" + "host='" + host + '\'' + ", ip='" + ip + '\'' + - ", capacity=" + capacity + + ", capacity=" + capacity + ", version='" + version + '\'' + '}'; }