diff --git a/spark/src/main/scala/org/apache/spark/sql/comet/operators.scala b/spark/src/main/scala/org/apache/spark/sql/comet/operators.scala index 0b98b62c06..dd1526d82c 100644 --- a/spark/src/main/scala/org/apache/spark/sql/comet/operators.scala +++ b/spark/src/main/scala/org/apache/spark/sql/comet/operators.scala @@ -523,7 +523,7 @@ case class CometSortExec( CometMetricNode.baselineMetrics(sparkContext) ++ Map( "spill_count" -> SQLMetrics.createMetric(sparkContext, "number of spills"), - "spilled_bytes" -> SQLMetrics.createNanoTimingMetric(sparkContext, "total spilled bytes")) + "spilled_bytes" -> SQLMetrics.createSizeMetric(sparkContext, "total spilled bytes")) } case class CometLocalLimitExec(