The GitHub Actions job "Java CI" on iceberg.git/flink-cdc-feature has failed. Run started by GitHub user fightBoxing (triggered by fightBoxing).
Head commit for run: 71934fee06fb0dba6b6cd8032b2fa71d023ddfbd / rockyyin <[email protected]> Flink: Add CDC (Change Data Capture) streaming read support This PR adds CDC support for Flink Iceberg source, allowing users to read changelog data with proper RowKind (INSERT, DELETE, UPDATE_BEFORE, UPDATE_AFTER). Key changes: - Add StreamingReadMode enum (APPEND_ONLY, CHANGELOG) - Add ChangelogDataIterator for iterating changelog scan tasks - Add RowDataChangelogScanTaskReader for reading changelog data - Add ChangelogScanSplit for CDC split handling - Add ChangelogRowDataReaderFunction for reader function support - Modify FlinkReadOptions/FlinkReadConf to support streaming-read-mode config - Modify ScanContext to support changelog scan mode - Modify FlinkSplitPlanner to plan changelog scan tasks - Modify ContinuousSplitPlannerImpl to support CDC mode - Modify IcebergSource to support streamingReadMode builder method - Modify IcebergTableSource to support CDC ChangelogMode - Add integration tests for CDC streaming read Usage: - Java API: IcebergSource.forRowData().streamingReadMode(StreamingReadMode.CHANGELOG) - SQL: SELECT * FROM table /*+ OPTIONS('streaming-read-mode' = 'CHANGELOG') */ Supported Flink versions: v1.20, v2.0, v2.1 Report URL: https://github.com/apache/iceberg/actions/runs/21852398463 With regards, GitHub Actions via GitBox
