Skip to content

Commit 41bcae9

Browse files
committed
fix equality
1 parent ca7e8d0 commit 41bcae9

File tree

2 files changed

+4
-5
lines changed

2 files changed

+4
-5
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plan/logical/Merge.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ public boolean expressionsResolved() {
4545

4646
@Override
4747
public int hashCode() {
48-
return Objects.hash(source().hashCode(), subPlans);
48+
return Objects.hash(subPlans);
4949
}
5050

5151
@Override
@@ -57,8 +57,7 @@ public boolean equals(Object o) {
5757
return false;
5858
}
5959
Merge other = (Merge) o;
60-
61-
return Objects.equals(source(), other.source()) && Objects.equals(subPlans, other.subPlans);
60+
return Objects.equals(subPlans, other.subPlans);
6261
}
6362

6463
@Override

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plan/physical/MergeExec.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -80,14 +80,14 @@ public List<? extends PhysicalPlan> subPlans() {
8080

8181
@Override
8282
public int hashCode() {
83-
return Objects.hash(source().hashCode(), physSubPlans);
83+
return Objects.hash(physSubPlans);
8484
}
8585

8686
@Override
8787
public boolean equals(Object o) {
8888
if (this == o) return true;
8989
if (o == null || getClass() != o.getClass()) return false;
9090
MergeExec other = (MergeExec) o;
91-
return Objects.equals(this.source(), other.source()) && Objects.equals(this.physSubPlans, other.physSubPlans);
91+
return Objects.equals(this.physSubPlans, other.physSubPlans);
9292
}
9393
}

0 commit comments

Comments
 (0)