HDFS-742. A down DataNode makes Balancer to hang on repeatingly asking NameNode its partial block list. Contributed by Mit Desai.
(cherry picked from commit 58db263e93
)
This commit is contained in:
parent
5c0db4e522
commit
33a87ffe10
|
@ -788,6 +788,13 @@ public class Dispatcher {
|
|||
+ ", scheduledSize=" + getScheduledSize()
|
||||
+ ", srcBlocks#=" + srcBlocks.size());
|
||||
}
|
||||
// check if time is up or not
|
||||
if (Time.monotonicNow() - startTime > MAX_ITERATION_TIME) {
|
||||
LOG.info("Time up (max time=" + MAX_ITERATION_TIME/1000
|
||||
+ " seconds). Skipping " + this);
|
||||
isTimeUp = true;
|
||||
continue;
|
||||
}
|
||||
final PendingMove p = chooseNextMove();
|
||||
if (p != null) {
|
||||
// Reset no pending move counter
|
||||
|
@ -825,14 +832,6 @@ public class Dispatcher {
|
|||
}
|
||||
}
|
||||
|
||||
// check if time is up or not
|
||||
if (Time.monotonicNow() - startTime > MAX_ITERATION_TIME) {
|
||||
LOG.info("Time up (max time=" + MAX_ITERATION_TIME/1000
|
||||
+ " seconds). Skipping " + this);
|
||||
isTimeUp = true;
|
||||
continue;
|
||||
}
|
||||
|
||||
// Now we can not schedule any block to move and there are
|
||||
// no new blocks added to the source block list, so we wait.
|
||||
try {
|
||||
|
|
Loading…
Reference in New Issue