This is an automated email from the ASF dual-hosted git repository.

adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git


The following commit(s) were added to refs/heads/master by this push:
     new 0171befb3d HDDS-13073. Set pipeline ID in checksums verifier to avoid 
cached pipeline with different node (#8480)
0171befb3d is described below

commit 0171befb3d5016b7a608adaaebde94d84fc07717
Author: Rishabh Patel <[email protected]>
AuthorDate: Wed May 21 09:19:52 2025 -0700

    HDDS-13073. Set pipeline ID in checksums verifier to avoid cached pipeline 
with different node (#8480)
---
 .../java/org/apache/hadoop/ozone/debug/replicas/ChecksumVerifier.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/debug/replicas/ChecksumVerifier.java
 
b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/debug/replicas/ChecksumVerifier.java
index 0f4729fbae..7f099bede0 100644
--- 
a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/debug/replicas/ChecksumVerifier.java
+++ 
b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/debug/replicas/ChecksumVerifier.java
@@ -60,6 +60,7 @@ public ChecksumVerifier(OzoneConfiguration conf) throws 
IOException {
   public BlockVerificationResult verifyBlock(DatanodeDetails datanode, 
OmKeyLocationInfo keyLocation,
                                              int replicaIndex) {
     Pipeline pipeline = Pipeline.newBuilder(keyLocation.getPipeline())
+        .setId(datanode.getID())
         .setReplicationConfig(StandaloneReplicationConfig.getInstance(ONE))
         .setNodes(Collections.singletonList(datanode))
         .setReplicaIndexes(Collections.singletonMap(datanode, replicaIndex))


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to