The GitHub Actions job "Flink CDC CI" on flink-cdc.git/fix/iceberg-duplication-same-checkpoint has failed. Run started by GitHub user spoorthibasu (triggered by lvyanquan).
Head commit for run: 725a8e4a7070976251da7eea4f5c158750681b35 / Spoorthi Basu <[email protected]> [iceberg] Restore flush to clear factory cache for schema reload flush(boolean) was a no-op to avoid splitting same-PK updates into multiple batches within a checkpoint. But without clearing the writer factory cache, new writes after a checkpoint could use a stale factory that doesn't reflect schema changes applied by IcebergMetadataApplier. Change flush to clear writerFactoryMap only. Writers themselves keep running so same-PK updates within a checkpoint go through the same writer and use position deletes (exact file+offset), which work correctly within a single snapshot without needing a separate seq_num. Schema-change flushes still go through flushTableWriter(tableId), which drains the writer and bumps batchIndex so equality-deletes land in a snapshot with a strictly higher sequence number than the data they target. Report URL: https://github.com/apache/flink-cdc/actions/runs/25245005510 With regards, GitHub Actions via GitBox
