Skip to content

Commit 04654f3

Browse files
committed
fix ReusedExchangeExec equals
1 parent 1634003 commit 04654f3

File tree

1 file changed

+2
-2
lines changed
  • sql/core/src/main/scala/org/apache/spark/sql/execution/exchange

1 file changed

+2
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/Exchange.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,11 +55,11 @@ case class ReusedExchangeExec(override val output: Seq[Attribute], child: Exchan
5555
extends LeafExecNode {
5656

5757
override def equals(that: Any): Boolean = that match {
58-
case ReusedExchangeExec(output, child) => this.child == output && this.child.eq(child)
58+
case ReusedExchangeExec(output, child) => this.output == output && this.child.id == child.id
5959
case _ => false
6060
}
6161

62-
override def hashCode: Int = Objects.hash(output, child)
62+
override def hashCode: Int = Objects.hash(output, child.id.asInstanceOf[AnyRef])
6363

6464
override def supportsColumnar: Boolean = child.supportsColumnar
6565

0 commit comments

Comments
 (0)