JingsongLi opened a new pull request, #9090: URL: https://github.com/apache/paimon/pull/9090
## What Make PyPaimon commits inherit the watermark from the latest snapshot. ## Why Paimon snapshots may omit the watermark only when neither the current commit nor the previous snapshot has one. PyPaimon currently creates every new snapshot without copying the latest watermark, which breaks watermark continuity in mixed Java/Python write histories and can invalidate watermark-based time travel. ## Impact After this change, a PyPaimon commit following a watermark-bearing Java/Flink snapshot preserves that watermark. Tables whose history has never carried a watermark continue to write snapshots without one. ## Tests - `python3 -m pytest pypaimon/tests/file_store_commit_test.py -q` - `python3 -m pytest pypaimon/tests/reader_append_only_test.py::AoReaderTest::test_commit_retry_filter -q` - `flake8 --config=./dev/cfg.ini pypaimon/write/file_store_commit.py pypaimon/tests/file_store_commit_test.py` - `git diff --check` -- 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]
