XiaoHongbo-Hope opened a new pull request, #9022: URL: https://github.com/apache/paimon/pull/9022
### Purpose Follow up on #8988 by making Data Evolution SQL DELETE compatible with Flink-derived planners which do not forward `RowLevelModificationScanContext` from the target source to the sink. The standard Flink context remains the primary path. During source planning, Paimon also records the exact planned snapshot in a thread-confined fallback keyed by table location and branch. The sink consumes it once only when the received context is `null`. This fallback never reads `latestSnapshot()` on the sink side. If planning moves to another thread or no Paimon source pinned a snapshot, DELETE still fails instead of risking an inconsistent deletion vector. The regression test commits a newer snapshot between source planning and sink setup, verifies that the sink retains the original planned snapshot through copies, and verifies that the fallback cannot be reused. The separate Flink Planner issue for DELETE projections containing only virtual metadata is outside this PR. ### Tests - `DataTableSourceTest` and `DataEvolutionDeleteSqlITCase`: 17 passed with Flink 1 profile - `paimon-flink-common` compiled successfully with Flink 2 profile - Spotless check and `git diff --check`: passed -- 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]
