Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21564#discussion_r195886078
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/Exchange.scala
---
@@ -70,7 +70,7 @@ case class ReusedExchangeExec(override val output:
Seq[Attribute], child: Exchan
}
override def outputPartitioning: Partitioning = child.outputPartitioning
match {
- case h: HashPartitioning => h.copy(expressions =
h.expressions.map(updateAttr))
+ case e: Expression => updateAttr(e).asInstanceOf[Partitioning]
case other => other
--- End diff --
LGTM
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
