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

HDFS-16427. Add debug log for BlockManager#chooseExcessRedundancyStriped (#3888)

Browse Source 
(cherry picked from commit 6136d630a351fa1a5dd668c318b20437e6aaa35b)
This commit is contained in:
litao 2022-01-27 12:42:44 +08:00 committed by Takanobu Asanuma
parent d613776b64
commit b5d2e00f81
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -4020,6 +4020,14 @@ private void chooseExcessRedundancyStriped(BlockCollection bc,
List<DatanodeStorageInfo> replicasToDelete = placementPolicy List<DatanodeStorageInfo> replicasToDelete = placementPolicy
.chooseReplicasToDelete(nonExcess, candidates, (short) 1, .chooseReplicasToDelete(nonExcess, candidates, (short) 1,
excessTypes, null, null); excessTypes, null, null);
if (LOG.isDebugEnabled()) {
LOG.debug("Choose redundant EC replicas to delete from blk_{} which is located in {}",
sblk.getBlockId(), storage2index);
LOG.debug("Storages with candidate blocks to be deleted: {}", candidates);
LOG.debug("Storages with blocks to be deleted: {}", replicasToDelete);
}
Preconditions.checkArgument(candidates.containsAll(replicasToDelete),
"The EC replicas to be deleted are not in the candidate list");
for (DatanodeStorageInfo chosen : replicasToDelete) { for (DatanodeStorageInfo chosen : replicasToDelete) {
processChosenExcessRedundancy(nonExcess, chosen, storedBlock); processChosenExcessRedundancy(nonExcess, chosen, storedBlock);
candidates.remove(chosen); candidates.remove(chosen);