jackylee-ch opened a new pull request, #10369:
URL: https://github.com/apache/paimon/pull/10369

   ### Purpose
   
   `PreAssignSplitAssigner#getNext` assigns splits while `assignment.size() < 
splitBatchSize`,
   so a non-positive `scan.split-enumerator.batch-size` makes that loop never 
run: the
   enumerator hands out no splits, `StaticFileStoreSplitEnumerator` reports 
no-more-splits on
   the first request, and a bounded read **silently returns zero rows** instead 
of failing.
   
   This validates the batch size is positive in the `PreAssignSplitAssigner` 
constructor — the
   single point every source builder (`FlinkSourceBuilder`, `SystemTableSource`,
   `CompactorSourceBuilder`) funnels through — so the misconfiguration fails 
fast at job start.
   The default is `10`, so valid configurations are unaffected.
   
   ### Tests
   
   `PreAssignSplitAssignerTest#testNonPositiveSplitBatchSizeRejected` asserts 
`0` and `-1` throw
   a clear `IllegalArgumentException`.
   
   ### API and Format
   
   No change.
   
   ### Documentation
   
   No change.
   


-- 
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]

Reply via email to