You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "suhwan (Jira)" <ji...@apache.org> on 2026/02/03 08:57:00 UTC

[jira] [Created] (FLINK-39019) [Iceberg] Support deletion vectors for format-version 3 tables

suhwan created FLINK-39019:
------------------------------

             Summary: [Iceberg] Support deletion vectors for format-version 3 tables
                 Key: FLINK-39019
                 URL: https://issues.apache.org/jira/browse/FLINK-39019
             Project: Flink
          Issue Type: New Feature
          Components: Flink CDC
            Reporter: suhwan


*Summary*

Implement deletion vector support in Flink CDC Iceberg connector to leverage format-version 3 performance benefits for CDC workloads.

 

*Content*

https://iceberg.apache.org/spec/#deletion-vectors

Iceberg format-version 3 introduces binary deletion vectors which replace positional delete files with compact bitmaps stored in Puffin files

(Current implementation uses equality delete files via `RowDataTaskWriterFactory`)

 

*Proposed Changes*
 # Check `table.properties().get("format-version")`
 ## For v3 tables with id fields -> use deletion vector
 ## etc tables -> use equality delete files



--
This message was sent by Atlassian Jira
(v8.20.10#820010)