diff --git a/src/java/voldemort/client/rebalance/task/DonorBasedRebalanceTask.java b/src/java/voldemort/client/rebalance/task/DonorBasedRebalanceTask.java
index 65dee13f0f..ce5a1f75fd 100644
--- 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
index 73830a723c..0e081b5682 100644
--- 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
index 5c08c388f5..37da1b90a9 100644
--- 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() {