HDFS-17003. Erasure coding: invalidate wrong block after reporting bad blocks from datanode

Author: hfutatzhanghb

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

@@ -3753,6 +3753,16 @@ private void invalidateCorruptReplicas(BlockInfo blk, Block reported,
         nodes.toArray(new DatanodeDescriptor[nodes.size()]);
     for (DatanodeDescriptor node : nodesCopy) {
       try {
+        if (blk.isStriped()) {
+          DatanodeStorageInfo[] storages = getStorages(blk);
+          // remove this block from the list of pending blocks to be deleted.
+          for (DatanodeStorageInfo storage : storages) {
+            final Block b = getBlockOnStorage(blk, storage);
+            if (b != null) {
+              reported = b;
+            }
+          }
+        }
         if (!invalidateBlock(new BlockToMarkCorrupt(reported, blk, null,
             Reason.ANY), node, numberReplicas)) {
           removedFromBlocksMap = false;