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))