The GitHub Actions job "Flink CDC CI" on 
flink-cdc.git/fix-duplicate-add-column-event has succeeded.
Run started by GitHub user dangerousfeng (triggered by lvyanquan).

Head commit for run:
0ff420f44f56aa12483e42241d7233253f3639f1 / weiqian.feng 
<[email protected]>
[FLINK-39412][cdc-common] Skip duplicate columns in AddColumnEvent to ensure 
idempotency

When recovering from a checkpoint/savepoint, binlog events may be replayed,
causing AddColumnEvent to be applied for columns that already exist in the
cached schema. This leads to duplicate field names in RowType, which throws
IllegalArgumentException: "Field names must be unique".

This fix adds an idempotency check in SchemaUtils.applyAddColumnEvent() to
skip columns that already exist in the schema, preventing the duplicate
column error during failover recovery.

Report URL: https://github.com/apache/flink-cdc/actions/runs/24175008112

With regards,
GitHub Actions via GitBox

Reply via email to