Skip to content

Commit 6950c26

Browse files
author
huanghaibin
committed
revert last change
1 parent 6685fbc commit 6950c26

File tree

1 file changed

+4
-5
lines changed
  • hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement

1 file changed

+4
-5
lines changed

hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3133,10 +3133,9 @@ private BlockInfo processReportedBlock(
31333133
final Collection<StatefulBlockInfo> toUC) {
31343134

31353135
DatanodeDescriptor dn = storageInfo.getDatanodeDescriptor();
3136-
if (LOG.isDebugEnabled()) {
3137-
LOG.debug("Reported block {} on {} size {} replicaState = {}", block, dn,
3138-
block.getNumBytes(), reportedState);
3139-
}
3136+
3137+
LOG.debug("Reported block {} on {} size {} replicaState = {}", block, dn,
3138+
block.getNumBytes(), reportedState);
31403139

31413140
if (shouldPostponeBlocksFromFuture && isGenStampInFuture(block)) {
31423141
queueReportedBlock(storageInfo, block, reportedState,
@@ -3173,7 +3172,7 @@ private BlockInfo processReportedBlock(
31733172
// comes from the IBR / FBR and hence what we should use to compare
31743173
// against the memory state.
31753174
// See HDFS-6289 and HDFS-15422 for more context.
3176-
queueReportedBlock(storageInfo, storedBlock, reportedState,
3175+
queueReportedBlock(storageInfo, block, reportedState,
31773176
QUEUE_REASON_CORRUPT_STATE);
31783177
} else {
31793178
toCorrupt.add(c);

0 commit comments

Comments
 (0)