File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
sql/core/src/test/scala/org/apache/spark/sql/execution Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -435,7 +435,8 @@ class PlannerSuite extends SharedSparkSession {
435435 val outputPlan = EnsureRequirements (spark.sessionState.conf).apply(inputPlan)
436436 assert(outputPlan.find {
437437 case ShuffleExchangeExec (_ : RoundRobinPartitioning , _, _) => true
438- case _ => false }.isEmpty,
438+ case _ => false
439+ }.isEmpty,
439440 " RoundRobinPartitioning should be changed to RangePartitioning" )
440441 }
441442
@@ -453,7 +454,8 @@ class PlannerSuite extends SharedSparkSession {
453454 val outputPlan = EnsureRequirements (spark.sessionState.conf).apply(inputPlan)
454455 assert(outputPlan.find {
455456 case ShuffleExchangeExec (_ : HashPartitioning , _, _) => true
456- case _ => false }.isEmpty,
457+ case _ => false
458+ }.isEmpty,
457459 " HashPartitioning should be changed to RangePartitioning" )
458460 }
459461
You can’t perform that action at this time.
0 commit comments