Correctly print RebalanceTask at creation time.

geir · Jun 20, 2013 · 77f3b69 · 77f3b69
1 parent ec9cd1e
commit 77f3b69
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/src/java/voldemort/client/rebalance/task/DonorBasedRebalanceTask.java b/src/java/voldemort/client/rebalance/task/DonorBasedRebalanceTask.java
@@ -49,6 +49,8 @@ public DonorBasedRebalanceTask(final int batchId,
 
         RebalanceUtils.assertSameDonor(stealInfos, -1);
         this.donorNodeId = stealInfos.get(0).getDonorId();
+
+        taskLog(toString());
     }
 
     @Override

diff --git a/src/java/voldemort/client/rebalance/task/RebalanceTask.java b/src/java/voldemort/client/rebalance/task/RebalanceTask.java
@@ -68,8 +68,6 @@ public RebalanceTask(final int batchId,
         this.partitionStoreCount = RebalanceUtils.countPartitionStores(stealInfos);
         this.permitAcquisitionTimeMs = -1;
         this.taskCompletionTimeMs = -1;
-
-        taskLog(toString());
     }
 
     public List<RebalancePartitionsInfo> getStealInfos() {
@@ -96,7 +94,7 @@ protected void acquirePermit(int nodeId) throws InterruptedException {
 
     @Override
     public String toString() {
-        return "Rebalance task " + taskId + "from batch " + batchId + " : " + getStealInfos();
+        return "Rebalance task " + taskId + " from batch " + batchId + " : " + getStealInfos();
     }
 
     /**

diff --git a/src/java/voldemort/client/rebalance/task/StealerBasedRebalanceTask.java b/src/java/voldemort/client/rebalance/task/StealerBasedRebalanceTask.java
@@ -78,6 +78,8 @@ public StealerBasedRebalanceTask(final int batchId,
 
         this.maxTries = maxTries;
         this.stealerNodeId = stealInfo.getStealerId();
+
+        taskLog(toString());
     }
 
     private int startNodeRebalancing() {