HDFS-16566.002.patch

RuinanGu · RuinanGu · commit 61c5aa627335 · 2022-05-01T06:49:55.000+08:00
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
@@ -2558,6 +2558,8 @@ DatanodeDescriptor[] chooseSourceDatanodes(BlockInfo block,
         if (isStriped && (state == StoredReplicaState.LIVE
             || state == StoredReplicaState.DECOMMISSIONING)) {
           liveBusyBlockIndices.add(blockIndex);
+          //HDFS-16566 ExcludeReconstructed won't be reconstructed
+          excludeReconstructed.add(blockIndex);
         }
         continue;
       }

Original file line number	Diff line number	Diff line change
`@@ -2558,6 +2558,8 @@ DatanodeDescriptor[] chooseSourceDatanodes(BlockInfo block,`
`2558`	`2558`	`if (isStriped && (state == StoredReplicaState.LIVE`
`2559`	`2559`	`\|\| state == StoredReplicaState.DECOMMISSIONING)) {`
`2560`	`2560`	`liveBusyBlockIndices.add(blockIndex);`
	`2561`	`+ //HDFS-16566 ExcludeReconstructed won't be reconstructed`
	`2562`	`+ excludeReconstructed.add(blockIndex);`
`2561`	`2563`	`}`
`2562`	`2564`	`continue;`
`2563`	`2565`	`}`