Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/19257#discussion_r152484490
--- 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 --
Could you add a comment to explain why we do it here. It is hard for new
comers to understand the assumptions we made here.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
