Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/19257#discussion_r152484350
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/EnsureRequirements.scala
---
@@ -31,6 +32,8 @@ import org.apache.spark.sql.internal.SQLConf
* input partition ordering requirements are met.
*/
case class EnsureRequirements(conf: SQLConf) extends Rule[SparkPlan] {
+ private val reorderJoinPredicates = new ReorderJoinPredicates
--- End diff --
Change `class ReorderJoinPredicates ` to `object ReorderJoinPredicates `?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
