In Balancer, the target task should be removed when its size < 0. Contributed by Yiqun Lin

2016-08-04 09:45:40 -07:00 · 2016-08-04 09:45:40 -07:00 · cefa21e98a
parent 1b97519987
commit cefa21e98a
1 changed files with 1 additions and 1 deletions
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/balancer/Dispatcher.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/balancer/Dispatcher.java
@ -734,7 +734,7 @@ private PendingMove chooseNextMove() {
            long blockSize = pendingBlock.block.getNumBytes();
            incScheduledSize(-blockSize);
            task.size -= blockSize;
-            if (task.size == 0) {
+            if (task.size <= 0) {
              i.remove();
            }
            return pendingBlock;