diff --git a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/scm/pipeline/Pipeline.java b/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/scm/pipeline/Pipeline.java index e198cae9373a..de0c1e932ccd 100644 --- a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/scm/pipeline/Pipeline.java +++ b/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/scm/pipeline/Pipeline.java @@ -468,7 +468,7 @@ public boolean equals(Object o) { return new EqualsBuilder() .append(id, that.id) .append(replicationConfig, that.replicationConfig) - .append(getNodes(), that.getNodes()) + .append(nodeStatus.keySet(), that.nodeStatus.keySet()) .isEquals(); }