malinjawi opened a new pull request, #13346:
URL: https://github.com/apache/gluten/pull/13346

   ## What changes are proposed in this pull request?
   
   Revives #12563, which the stale bot closed without review. Rebased onto main.
   
   With 
`spark.gluten.sql.columnar.backend.velox.valueStream.dynamicFilter.enabled=true`
 (#11657, off by default), `ValueStreamDataSource::next()` calls itself once 
for every batch the dynamic filter removes entirely, so a long run of such 
batches grows the native stack and can overflow the executor thread. This makes 
the retry a loop, with no other behavior change. It's needed before the filter 
from #11605 can be on by default.
   
   ## How was this patch tested?
   
   A new `manyConsecutiveFullyFilteredBatches` case in 
`ValueStreamDynamicFilterTest` (`velox_operators_test`) filters out 4096 
consecutive batches in one split and checks that the batch after them still 
comes through.
   
   ## Was this patch authored or co-authored using generative AI tooling?
   
   Generated-by: IBM Bob
   
   cc @acvictor @zhztheplayer
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to