Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/19257#discussion_r152484440
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/EnsureRequirements.scala
---
@@ -265,6 +268,7 @@ case class EnsureRequirements(conf: SQLConf) extends
Rule[SparkPlan] {
if (childPartitioning.guarantees(partitioning)) child else
operator
case _ => operator
}
- case operator: SparkPlan => ensureDistributionAndOrdering(operator)
+ case operator: SparkPlan =>
+ ensureDistributionAndOrdering(reorderJoinPredicates.apply(operator))
--- End diff --
Then, do something like
```Scala
ensureDistributionAndOrdering(ReorderJoinPredicates(operator))
```
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
