Apache/hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-9618. Fix mismatch between log level and guard in BlockManager#computeRecoveryWorkForBlocks (iwasakims)

Browse Source
This commit is contained in:
Masatake Iwasaki 2016-01-22 14:12:06 +09:00
parent 844a8e3771
commit 73ef77c12f
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -57,6 +57,9 @@ Release 2.9.0 - UNRELEASED
HDFS-9601. NNThroughputBenchmark.BlockReportStats should handle HDFS-9601. NNThroughputBenchmark.BlockReportStats should handle
NotReplicatedYetException on adding block (iwasakims) NotReplicatedYetException on adding block (iwasakims)
HDFS-9618. Fix mismatch between log level and guard in
BlockManager#computeRecoveryWorkForBlocks (iwasakims)
HDFS-9621. Consolidate FSDirStatAndListingOp#createFileStatus to let its HDFS-9621. Consolidate FSDirStatAndListingOp#createFileStatus to let its
INodesInPath parameter always include the target INode. (jing9) INodesInPath parameter always include the target INode. (jing9)

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

@ -1389,7 +1389,7 @@ int computeReplicationWorkForBlocks(List<List<BlockInfo>> blocksToReplicate) {
namesystem.writeUnlock(); namesystem.writeUnlock();
} }
if (blockLog.isInfoEnabled()) { if (blockLog.isDebugEnabled()) {
// log which blocks have been scheduled for replication // log which blocks have been scheduled for replication
for(ReplicationWork rw : work){ for(ReplicationWork rw : work){
DatanodeStorageInfo[] targets = rw.getTargets(); DatanodeStorageInfo[] targets = rw.getTargets();
@ -1403,8 +1403,7 @@ int computeReplicationWorkForBlocks(List<List<BlockInfo>> blocksToReplicate) {
rw.getBlock(), targetList); rw.getBlock(), targetList);
} }
} }
}
if (blockLog.isDebugEnabled()) {
blockLog.debug("BLOCK* neededReplications = {} pendingReplications = {}", blockLog.debug("BLOCK* neededReplications = {} pendingReplications = {}",
neededReplications.size(), pendingReplications.size()); neededReplications.size(), pendingReplications.size());
} }