misc

jiajunmao · Sep 2, 2024 · 5658d73 · 5658d73
1 parent de95491
commit 5658d73
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 2 deletions.
diff --git a/...src/main/java/org/apache/hadoop/hdfs/server/datanode/erasurecode/ErasureCodingWorker.java b/...src/main/java/org/apache/hadoop/hdfs/server/datanode/erasurecode/ErasureCodingWorker.java
@@ -137,13 +137,14 @@ public void processErasureCodingTasks(
                 + "poolId {}, blockId {}\n"
                 + "target data nodes {}\n"
                 + "target storage type {}, id {}\n"
-                + "zfs failure indices {}, {}",
+                + "zfs failure indices {}, {}, {}",
                 reconInfo.getExtendedBlock().getBlockPoolId(),
                 reconInfo.getExtendedBlock().getBlockId(),
                 targetDataNodesStr,
                 reconInfo.getTargetStorageTypes(), reconInfo.getTargetStorageIDs(),
                 reconInfo.getZfsFailureIndices(),
-                reconInfo.getLiveBlockIndices());
+                reconInfo.getLiveBlockIndices(),
+                reconInfo.getLocalBlockId());
 
         // MLEC - register ongoing repairs
         LOG.info("Adding block {} to ongoing reconstruction map", reconInfo.getExtendedBlock().getLocalBlock().getBlockId());

diff --git a/...fs/src/main/java/org/apache/hadoop/hdfs/server/protocol/BlockECReconstructionCommand.java b/...fs/src/main/java/org/apache/hadoop/hdfs/server/protocol/BlockECReconstructionCommand.java
@@ -152,6 +152,14 @@ public List<Integer> getZfsFailureIndices() {
       return zfsFailureIndices;
     }
 
+    public long getLocalBlockId() {
+      return this.localBlockId;
+    }
+
+    public void setLocalBlockId(long localBlockId) {
+      this.localBlockId = localBlockId;
+    }
+
     @Override
     public String toString() {
       return new StringBuilder().append("BlockECReconstructionInfo(\n  ")
@@ -160,6 +168,7 @@ public String toString() {
           .append(Arrays.asList(targets)).append(")\n")
           .append(" Block Indices: ").append(Arrays.toString(liveBlockIndices))
           .append(" Zfs Failure Indices: ").append(zfsFailureIndices)
+          .append(" Local Block Id: ").append(localBlockId)
           .toString();
     }
   }