XiaoHongbo-Hope opened a new pull request, #8988: URL: https://github.com/apache/paimon/pull/8988
### Purpose Support `DELETE FROM ... WHERE ...` in Flink batch SQL for Data Evolution append tables with row tracking and deletion vectors enabled. The target table scan is pinned to one snapshot and exposes `_ROW_ID` as a metadata column. Matching row IDs are written into deletion vectors without rewriting data files. The commit keeps strict snapshot and row-ID conflict detection, and the scan uses full scalar-index search so rows outside existing index coverage are not missed. This also extracts the existing Data Evolution delete-action sink into a shared implementation, preserves the action behavior, handles empty tables as a fixed empty snapshot, and documents the new SQL support. Streaming DELETE remains unsupported. ### Tests - `DataEvolutionDeleteSqlITCase`: 5 passed - `DataTableSourceTest`: 7 passed - `DeleteActionDataEvolutionITCase`: 12 passed - `DeletionVectorITCase#testRemoveDvsAfterFullCompaction`: passed - Spotless 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]
