Enable output batches metric for GpuShuffleCoalesceExec by default (N…

…VIDIA#8619) Signed-off-by: Jason Lowe <jlowe@nvidia.com>
mythrocks · Jun 28, 2023 · d458599 · d458599
1 parent 2cad130
commit d458599
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuShuffleCoalesceExec.scala b/sql-plugin/src/main/scala/com/nvidia/spark/rapids/GpuShuffleCoalesceExec.scala
@@ -51,6 +51,8 @@ case class GpuShuffleCoalesceExec(child: SparkPlan, targetBatchByteSize: Long)
     CONCAT_TIME -> createNanoTimingMetric(DEBUG_LEVEL, DESCRIPTION_CONCAT_TIME)
   )
 
+  override protected val outputBatchesLevel = MODERATE_LEVEL
+
   override def output: Seq[Attribute] = child.output
 
   override def outputPartitioning: Partitioning = child.outputPartitioning