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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
