QuakeWang opened a new pull request, #8041: URL: https://github.com/apache/paimon/pull/8041
### Purpose `PaimonDatasink.on_write_complete()` previously returned early when all Ray write tasks produced empty commit messages. This made `write_paimon(empty_ds, table, overwrite=True)` a silent no-op, so existing data was kept even though Paimon overwrite commit semantics require empty overwrite commits to reach `TableCommit`. This PR keeps the empty-message fast path only for append writes. For overwrite writes, Ray now calls `TableCommit.commit([])`, allowing `FileStoreCommit.overwrite()` to delete the target range for static/unpartitioned overwrite and preserve dynamic-partition empty overwrite no-op semantics. ### Tests - `python -m pytest pypaimon/tests/ray_sink_test.py pypaimon/tests/ray_integration_test.py::RayIntegrationTest::test_write_paimon_empty_overwrite_unpartitioned` -- 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]
