Fix JVM R2C operator metrics (#1067)

oap-project · Aug 15, 2022 · cce191a · cce191a
1 parent 6661b7b
commit cce191a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ata-source/common/src/main/scala/com/intel/oap/sql/execution/RowToArrowColumnarExec.scala b/...ata-source/common/src/main/scala/com/intel/oap/sql/execution/RowToArrowColumnarExec.scala
@@ -279,13 +279,13 @@ case class RowToArrowColumnarExec(child: SparkPlan) extends UnaryExecNode {
         val res = new Iterator[ColumnarBatch] {
           private val converters = new RowToColumnConverter(localSchema)
           private var last_cb: ColumnarBatch = null
-          private var elapse: Long = 0
 
           override def hasNext: Boolean = {
             rowIterator.hasNext
           }
 
           override def next(): ColumnarBatch = {
+            var elapse: Long = 0
             val vectors: Seq[WritableColumnVector] =
               ArrowWritableColumnVector.allocateColumns(numRows, schema)
             var rowCount = 0