From e137cb75c56600e35e4bfa41093272b9f6ee5581 Mon Sep 17 00:00:00 2001 From: sarvekshayr Date: Tue, 3 Jun 2025 11:42:06 +0530 Subject: [PATCH] HDDS-13166. Set pipeline ID in BlockExistenceVerifier to avoid cached pipeline with different node --- .../hadoop/ozone/debug/replicas/BlockExistenceVerifier.java | 1 + 1 file changed, 1 insertion(+) diff --git a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/debug/replicas/BlockExistenceVerifier.java b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/debug/replicas/BlockExistenceVerifier.java index 9d910700ea40..6970e951c86c 100644 --- a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/debug/replicas/BlockExistenceVerifier.java +++ b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/debug/replicas/BlockExistenceVerifier.java @@ -56,6 +56,7 @@ public BlockVerificationResult verifyBlock(DatanodeDetails datanode, OmKeyLocati XceiverClientSpi client = null; try { Pipeline pipeline = Pipeline.newBuilder(keyLocation.getPipeline()) + .setId(datanode.getID()) .setReplicationConfig(StandaloneReplicationConfig.getInstance(ONE)) .setNodes(Collections.singletonList(datanode)) .setReplicaIndexes(Collections.singletonMap(datanode, replicaIndex))