You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@paimon.apache.org by "QuakeWang (via GitHub)" <gi...@apache.org> on 2026/06/02 13:20:30 UTC

[PR] [python][ray] Honor partition overwrite in write_ray [paimon]

QuakeWang opened a new pull request, #8088:
URL: https://github.com/apache/paimon/pull/8088

   ### Purpose
   
   `TableWrite.write_ray()` previously did not carry builder-level overwrite partitions into the Ray datasink. As a result, `table.new_batch_write_builder().overwrite({...}).new_write().write_ray(...)` wrote through Ray without the configured partition overwrite contract, while `overwrite=True` only supported full-table overwrite.
   
   This PR carries the builder static partition into `TableWrite`, forwards it to `PaimonDatasink`, and applies the same overwrite partition on both Ray write tasks and the driver-side commit path.
   
   ### Tests
   
     - `python -m py_compile` on changed Python files
     - `pycodestyle` with project flake8 options on changed Python files
     - `pyflakes` on changed Python files


-- 
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: issues-unsubscribe@paimon.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [PR] [python][ray] Honor partition overwrite in write_ray [paimon]

Posted by "JingsongLi (via GitHub)" <gi...@apache.org>.
JingsongLi merged PR #8088:
URL: https://github.com/apache/paimon/pull/8088


-- 
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: issues-unsubscribe@paimon.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org