Skip to content

Commit 0672377

Browse files
committed
fix
1 parent e8dd501 commit 0672377

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/aggregate/AggFuncEvaluator.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ import org.apache.spark.sql.types.{DataType, LongType}
2929
import org.apache.spark.unsafe.types.UTF8String
3030

3131
trait AggFuncEvaluator[T] {
32+
3233
def update(dataSplit: DataSplit): Unit
3334

3435
def result(): T
@@ -42,7 +43,7 @@ class CountStarEvaluator extends AggFuncEvaluator[Long] {
4243
private var _result: Long = 0L
4344

4445
override def update(dataSplit: DataSplit): Unit = {
45-
_result += dataSplit.mergedRowCount()
46+
_result += dataSplit.mergedRowCount().getAsLong
4647
}
4748

4849
val a: Int = 1;

0 commit comments

Comments
 (0)