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

This commit is contained in:
Tsz-Wo Nicholas Sze 2016-08-04 09:45:40 -07:00
parent 9422515239
commit 8c9b44eaff
1 changed files with 1 additions and 1 deletions

View File

@ -795,7 +795,7 @@ public class Dispatcher {
long blockSize = pendingBlock.reportedBlock.getNumBytes(this);
incScheduledSize(-blockSize);
task.size -= blockSize;
if (task.size == 0) {
if (task.size <= 0) {
i.remove();
}
return pendingBlock;