QuakeWang opened a new pull request, #8483:
URL: https://github.com/apache/paimon/pull/8483
### Purpose
`TableUpdateByRowId._write_group()` used to close writers when an exception
happened after data/blob files had already been written but before commit
messages were returned. `close()` preserves prepared files, so failed
update-by-row-id jobs could leave orphan data or blob files even though no
manifest commit happened.
This PR tracks whether the write group completed successfully. On failure,
it aborts the `FileStoreWrite` and any `BlobWriter`s so their already-written
files are cleaned up. Successful writes still follow the existing close path.
### Tests
- `python -m py_compile pypaimon/write/table_update_by_row_id.py
pypaimon/tests/table_update_test.py`
- `python -m pytest pypaimon/tests/table_update_test.py -q`
- `python -m pytest
pypaimon/tests/blob_table_test.py::DedicatedFormatWriterTest::test_update_blob_column
-q`
--
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]
