|
@@ -659,7 +659,6 @@ public class BlockPlacementPolicyDefault extends BlockPlacementPolicy {
|
|
|
|
|
|
int numOfAvailableNodes = clusterMap.countNumOfAvailableNodes(
|
|
|
scope, excludedNodes);
|
|
|
- int refreshCounter = numOfAvailableNodes;
|
|
|
StringBuilder builder = null;
|
|
|
if (LOG.isDebugEnabled()) {
|
|
|
builder = debugLoggingBuilder.get();
|
|
@@ -709,17 +708,6 @@ public class BlockPlacementPolicyDefault extends BlockPlacementPolicy {
|
|
|
// If no candidate storage was found on this DN then set badTarget.
|
|
|
badTarget = (storage == null);
|
|
|
}
|
|
|
- // Refresh the node count. If the live node count became smaller,
|
|
|
- // but it is not reflected in this loop, it may loop forever in case
|
|
|
- // the replicas/rack cannot be satisfied.
|
|
|
- if (--refreshCounter == 0) {
|
|
|
- refreshCounter = clusterMap.countNumOfAvailableNodes(scope,
|
|
|
- excludedNodes);
|
|
|
- // It has already gone through enough number of nodes.
|
|
|
- if (refreshCounter <= excludedNodes.size()) {
|
|
|
- break;
|
|
|
- }
|
|
|
- }
|
|
|
}
|
|
|
|
|
|
if (numOfReplicas>0) {
|