You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@flink.apache.org by GitBox <gi...@apache.org> on 2026/05/03 10:50:09 UTC
[GH] (flink-cdc/fix/iceberg-duplication-same-checkpoint): Workflow run "Flink CDC CI" failed!
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 <sp...@gmail.com>
[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