fix ReusedExchangeExec equals

peter-toth · peter-toth · commit a3978f0add8f · 2019-11-11T08:28:41.000+01:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/Exchange.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/Exchange.scala
@@ -55,7 +55,7 @@ case class ReusedExchangeExec(override val output: Seq[Attribute], child: Exchan
   extends LeafExecNode {
 
   override def equals(that: Any): Boolean = that match {
-    case ReusedExchangeExec(output, child) => this.child == output && this.child.eq(child)
+    case ReusedExchangeExec(output, child) => this.output == output && this.child.eq(child)
     case _ => false
   }
 

Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@ case class ReusedExchangeExec(override val output: Seq[Attribute], child: Exchan`
`55`	`55`	`extends LeafExecNode {`
`56`	`56`
`57`	`57`	`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.eq(child)`
`59`	`59`	`case _ => false`
`60`	`60`	`}`
`61`	`61`