fix

zhengchenyu · zhengchenyu · commit dd74849c9d24 · 2024-08-21T10:02:21.000+08:00
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ErasureCodingReplicationWork.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ErasureCodingReplicationWork.java
@@ -68,7 +68,7 @@ void chooseTargets(BlockPlacementPolicy blockplacement,
   }
 
   @Override
-  void addTaskToDatanode(NumberReplicas numberReplicas) {
+  boolean addTaskToDatanode(NumberReplicas numberReplicas) {
     for (int i = 0; i < getSrcNodes().length && i < getTargets().length; i++) {
       BlockInfoStriped stripedBlk = (BlockInfoStriped) getBlock();
       final byte blockIndex = srcIndices[i];
@@ -83,6 +83,7 @@ void addTaskToDatanode(NumberReplicas numberReplicas) {
       LOG.debug("Add replication task from source {} to "
           + "target {} for EC block {}", source, target, targetBlk);
     }
+    return true;
   }
 
   @VisibleForTesting

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ void chooseTargets(BlockPlacementPolicy blockplacement,`
`68`	`68`	`}`
`69`	`69`
`70`	`70`	`@Override`
`71`		`- void addTaskToDatanode(NumberReplicas numberReplicas) {`
	`71`	`+ boolean addTaskToDatanode(NumberReplicas numberReplicas) {`
`72`	`72`	`for (int i = 0; i < getSrcNodes().length && i < getTargets().length; i++) {`
`73`	`73`	`BlockInfoStriped stripedBlk = (BlockInfoStriped) getBlock();`
`74`	`74`	`final byte blockIndex = srcIndices[i];`
`@@ -83,6 +83,7 @@ void addTaskToDatanode(NumberReplicas numberReplicas) {`
`83`	`83`	`LOG.debug("Add replication task from source {} to "`
`84`	`84`	`+ "target {} for EC block {}", source, target, targetBlk);`
`85`	`85`	`}`
	`86`	`+ return true;`
`86`	`87`	`}`
`87`	`88`
`88`	`89`	`@VisibleForTesting`