diff --git a/spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala b/spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala index 9a39e53826..8e55a460c2 100644 --- a/spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala +++ b/spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala @@ -512,7 +512,7 @@ class CometExecSuite extends CometTestBase { assert(metrics.contains("input_rows")) assert(metrics("input_rows").value == 10L) assert(metrics.contains("output_batches")) - assert(metrics("output_batches").value == 4L) + assert(metrics("output_batches").value == 1L) assert(metrics.contains("output_rows")) assert(metrics("output_rows").value == 5L) assert(metrics.contains("peak_mem_used"))