use constant, fix typo

apache · Nov 29, 2024 · db42583 · db42583
1 parent 5631853
commit db42583
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/common/src/main/scala/org/apache/comet/vector/NativeUtil.scala b/common/src/main/scala/org/apache/comet/vector/NativeUtil.scala
@@ -143,7 +143,7 @@ class NativeUtil {
    * @param numOutputCols
    *   The number of output columns
    * @param arrowFfiMetric
-   *   SQLMetric to record time spend performing Arrow FFI to transfer batches from native to JVM
+   *   SQLMetric to record time performing Arrow FFI to transfer batches from native to JVM
    * @param func
    *   The function to call to get the next batch
    * @return

diff --git a/spark/src/test/scala/org/apache/comet/CometNativeSuite.scala b/spark/src/test/scala/org/apache/comet/CometNativeSuite.scala
@@ -22,7 +22,7 @@ package org.apache.comet
 import org.apache.spark.SparkException
 import org.apache.spark.sql.CometTestBase
 import org.apache.spark.sql.catalyst.expressions.PrettyAttribute
-import org.apache.spark.sql.comet.{CometExec, CometExecUtils}
+import org.apache.spark.sql.comet.{CometExec, CometExecUtils, CometMetricNode}
 import org.apache.spark.sql.execution.metric.SQLMetrics
 import org.apache.spark.sql.types.LongType
 import org.apache.spark.sql.vectorized.ColumnarBatch
@@ -39,7 +39,8 @@ class CometNativeSuite extends CometTestBase {
         }),
         1,
         limitOp,
-        SQLMetrics.createNanoTimingMetric(spark.sparkContext, "Arrow FFI Time"),
+        SQLMetrics
+          .createNanoTimingMetric(spark.sparkContext, CometMetricNode.ARROW_FFI_TIME_DESCRIPTION),
         1,
         0)
       cometIter.next()