|
@@ -1195,19 +1195,16 @@ public class BlockManager implements BlockStatsMXBean {
|
|
if (!isPopulatingReplQueues()) {
|
|
if (!isPopulatingReplQueues()) {
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
- StringBuilder datanodes = blockLog.isDebugEnabled()
|
|
|
|
- ? new StringBuilder() : null;
|
|
|
|
|
|
+ StringBuilder datanodes = new StringBuilder();
|
|
for (DatanodeStorageInfo storage : blocksMap.getStorages(b)) {
|
|
for (DatanodeStorageInfo storage : blocksMap.getStorages(b)) {
|
|
if (storage.getState() != State.NORMAL) {
|
|
if (storage.getState() != State.NORMAL) {
|
|
continue;
|
|
continue;
|
|
}
|
|
}
|
|
final DatanodeDescriptor node = storage.getDatanodeDescriptor();
|
|
final DatanodeDescriptor node = storage.getDatanodeDescriptor();
|
|
invalidateBlocks.add(b, node, false);
|
|
invalidateBlocks.add(b, node, false);
|
|
- if (datanodes != null) {
|
|
|
|
- datanodes.append(node).append(" ");
|
|
|
|
- }
|
|
|
|
|
|
+ datanodes.append(node).append(" ");
|
|
}
|
|
}
|
|
- if (datanodes != null & datanodes.length() != 0) {
|
|
|
|
|
|
+ if (datanodes.length() != 0) {
|
|
blockLog.debug("BLOCK* addToInvalidates: {} {}", b, datanodes);
|
|
blockLog.debug("BLOCK* addToInvalidates: {} {}", b, datanodes);
|
|
}
|
|
}
|
|
}
|
|
}
|