JingsongLi opened a new pull request, #885: URL: https://github.com/apache/paimon-rust/pull/885
## Summary - add an idempotent close API to the Python RecordBatchReader - interrupt an in-flight async next operation without waiting on the stream mutex - release the native stream promptly and document the API in the Python type stub - cover pending-read cancellation plus Python close/EOF behavior ## Motivation Parallel PyPaimon reads may close after one reader produces a batch while another reader is still blocked in its first native read. The Python executor cannot finish until that in-flight Rust operation is cancellable. The close path uses an atomic flag and Tokio Notify, so it does not contend on the mutex held by next_record_batch. ## Tests - cargo test -p pypaimon_rust record_batch_reader_close_interrupts_pending_next --locked - cargo clippy -p pypaimon_rust --all-targets --locked -- -D warnings - python -m pytest -q bindings/python/tests/test_read.py (82 passed) -- 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]
