(gluten) branch main updated: [VL] Close ColumnarBatch in ColumnarCollectLimitExec for skipped batches (#11754)

[ch...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

chengchengjin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gluten.git


The following commit(s) were added to refs/heads/main by this push:
     new dd652bb528 [VL] Close ColumnarBatch in ColumnarCollectLimitExec for skipped batches (#11754)
dd652bb528 is described below

commit dd652bb528042219800fd8866b6aa05e927b7f8c
Author: Ankita Victor <an...@microsoft.com>
AuthorDate: Mon Mar 16 19:55:26 2026 +0530

    [VL] Close ColumnarBatch in ColumnarCollectLimitExec for skipped batches (#11754)
---
 .../scala/org/apache/gluten/execution/ColumnarCollectLimitExec.scala     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/backends-velox/src/main/scala/org/apache/gluten/execution/ColumnarCollectLimitExec.scala b/backends-velox/src/main/scala/org/apache/gluten/execution/ColumnarCollectLimitExec.scala
index 61c42715ea..a3ee421e59 100644
--- a/backends-velox/src/main/scala/org/apache/gluten/execution/ColumnarCollectLimitExec.scala
+++ b/backends-velox/src/main/scala/org/apache/gluten/execution/ColumnarCollectLimitExec.scala
@@ -70,6 +70,7 @@ case class ColumnarCollectLimitExec(
 
           if (rowsToSkip >= batchSize) {
             rowsToSkip -= batchSize
+            batch.close()
           } else {
             val startIndex = rowsToSkip
             val leftoverAfterSkip = batchSize - startIndex


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@gluten.apache.org
For additional commands, e-mail: commits-help@gluten.apache.org