Kyligence#217 fix AE remove root ShuffleExchangeExec which generated …

…by RepartitionByExpression
7mming7 · Feb 26, 2021 · a776ab0 · a776ab0
1 parent 0610856
commit a776ab0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/PlannerSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/PlannerSuite.scala
@@ -430,7 +430,7 @@ class PlannerSuite extends SharedSQLContext {
       partitioning,
       DummySparkPlan(outputPartitioning = partitioning),
       None,
-      None)
+      Some(false))
     val outputPlan = EnsureRequirements(spark.sessionState.conf).apply(inputPlan)
     assertDistributionRequirementsAreSatisfied(outputPlan)
     if (outputPlan.collect { case e: ShuffleExchangeExec => true }.size == 1) {