diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java index 12802ebb625..ca4f3336b5e 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java @@ -1195,19 +1195,16 @@ private void addToInvalidates(Block b) { if (!isPopulatingReplQueues()) { return; } - StringBuilder datanodes = blockLog.isDebugEnabled() - ? new StringBuilder() : null; + StringBuilder datanodes = new StringBuilder(); for (DatanodeStorageInfo storage : blocksMap.getStorages(b)) { if (storage.getState() != State.NORMAL) { continue; } final DatanodeDescriptor node = storage.getDatanodeDescriptor(); 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); } }