diff --git a/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuTransitionOverrides.scala b/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuTransitionOverrides.scala index 644d862aeed..0ace98b5dfc 100644 --- a/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuTransitionOverrides.scala +++ b/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuTransitionOverrides.scala @@ -694,7 +694,7 @@ class GpuTransitionOverrides extends Rule[SparkPlan] { }.getOrElse(g) } } - + logInfo(s"==> start fixupAdaptiveExchangeReuse, input plan is: \n $p") // If an exchange is at the top of the plan being remapped, this is likely due to AQE // re-planning, and we're not allowed to change an exchange to a reused exchange in that case. p match { diff --git a/sql-plugin/src/main/scala/com/nvidia/spark/rapids/SupportPlanningMark.scala b/sql-plugin/src/main/scala/com/nvidia/spark/rapids/SupportPlanningMark.scala index bbf1efcb969..6b6d90dd9f0 100644 --- a/sql-plugin/src/main/scala/com/nvidia/spark/rapids/SupportPlanningMark.scala +++ b/sql-plugin/src/main/scala/com/nvidia/spark/rapids/SupportPlanningMark.scala @@ -22,10 +22,10 @@ import scala.ref.WeakReference import org.apache.spark.internal.Logging import org.apache.spark.sql.execution.exchange.Exchange -/**A trait mixed with a GPU version of Exchange to support to mark if it is optimized by GPU*/ +/** A trait mixed with a GPU version of Exchange to support to mark if it is optimized by GPU */ trait SupportPlanningMark extends Logging { this: Exchange => - // Some GPU Shuffle exchanges are used internally without a CPU instance, it is an Option. + // Some GPU Shuffle exchanges are used internally without a CPU instance, So it is an Option. val cpuCanonicalExec: Option[Exchange] private var _isGpuPlanningComplete = false