remove the println

apache · Jul 7, 2020 · 947927a · 947927a
1 parent 479d56b
commit 947927a
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/OptimizeSkewedJoin.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/adaptive/OptimizeSkewedJoin.scala
@@ -300,9 +300,7 @@ case class OptimizeSkewedJoin(conf: SQLConf) extends Rule[SparkPlan] {
       //     ..
       //       Shuffle
       val optimizePlan = optimizeSkewJoin(plan)
-      val ensuredPlan = ensureRequirements.apply(optimizePlan)
-      println(ensuredPlan)
-      val numShuffles = ensuredPlan.collect {
+      val numShuffles = ensureRequirements.apply(optimizePlan).collect {
         case e: ShuffleExchangeExec => e
       }.length