big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDFS-7962. Remove duplicated logs in BlockManager. (yliu)

Browse Source
This commit is contained in:
yliu 2015-03-20 05:29:25 +08:00
parent 4e886eb9cb
commit 978ef11f26
2 changed files with 10 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt
View File

@ -767,6 +767,8 @@ Release 2.7.0 - UNRELEASED
HDFS.7849. Update documentation for enabling a new feature in rolling HDFS.7849. Update documentation for enabling a new feature in rolling
upgrade ( J.Andreina via vinayakumarb ) upgrade ( J.Andreina via vinayakumarb )
HDFS-7962. Remove duplicated logs in BlockManager. (yliu)
OPTIMIZATIONS OPTIMIZATIONS
HDFS-7454. Reduce memory footprint for AclEntries in NameNode. HDFS-7454. Reduce memory footprint for AclEntries in NameNode.

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

@ -1222,10 +1222,6 @@ private boolean invalidateBlock(BlockToMarkCorrupt b, DatanodeInfo dn
// Check how many copies we have of the block // Check how many copies we have of the block
NumberReplicas nr = countNodes(b.stored); NumberReplicas nr = countNodes(b.stored);
if (nr.replicasOnStaleNodes() > 0) { if (nr.replicasOnStaleNodes() > 0) {
blockLog.info("BLOCK* invalidateBlocks: postponing " +
"invalidation of " + b + " on " + dn + " because " +
nr.replicasOnStaleNodes() + " replica(s) are located on nodes " +
"with potentially out-of-date block reports");
blockLog.info("BLOCK* invalidateBlocks: postponing " + blockLog.info("BLOCK* invalidateBlocks: postponing " +
"invalidation of {} on {} because {} replica(s) are located on " + "invalidation of {} on {} because {} replica(s) are located on " +
"nodes with potentially out-of-date block reports", b, dn, "nodes with potentially out-of-date block reports", b, dn,
@ -1496,8 +1492,10 @@ int computeReplicationWorkForBlocks(List<List<Block>> blocksToReplicate) {
} }
} }
} }
if (blockLog.isDebugEnabled()) {
blockLog.debug("BLOCK* neededReplications = {} pendingReplications = {}", blockLog.debug("BLOCK* neededReplications = {} pendingReplications = {}",
neededReplications.size(), pendingReplications.size()); neededReplications.size(), pendingReplications.size());
}
return scheduledWork; return scheduledWork;
} }
@ -2477,9 +2475,6 @@ private Block addStoredBlock(final BlockInfoContiguous block,
} }
} else if (result == AddBlockResult.REPLACED) { } else if (result == AddBlockResult.REPLACED) {
curReplicaDelta = 0; curReplicaDelta = 0;
blockLog.warn("BLOCK* addStoredBlock: " + "block " + storedBlock
+ " moved to storageType " + storageInfo.getStorageType()
+ " on node " + node);
blockLog.warn("BLOCK* addStoredBlock: block {} moved to storageType " + blockLog.warn("BLOCK* addStoredBlock: block {} moved to storageType " +
"{} on node {}", storedBlock, storageInfo.getStorageType(), node); "{} on node {}", storedBlock, storageInfo.getStorageType(), node);
} else { } else {