The GitHub Actions job "Flink CDC CI" on 
flink-cdc.git/fix-drop-table-schema-state has failed.
Run started by GitHub user taoran92 (triggered by taoran92).

Head commit for run:
69821d1c1b28308c80a29b742985ab8975816963 / Ran Tao <[email protected]>
[FLINK-39965][runtime] Correct schema state after DropTableEvent

DropTableEvent can remove a downstream table while the runtime still keeps 
original/evolved schema state and table-level caches for the same table id. 
When the upstream table
is created again, the following CreateTableEvent may be treated as redundant, 
skipped by sink initialization, or forwarded as a duplicate create event if 
drop.table was
filtered out.

This change removes schema state for dropped tables and updates the regular 
schema derivation to distinguish between two cases: forward DropTableEvent only 
when no upstream
dependency remains, and derive schema differences when a later CreateTableEvent 
targets an existing downstream schema. It also clears table-level caches in 
transform,
pre-partition, and sink wrapper operators so recreated tables can be 
initialized with their new schema.

This also avoids recreating pre-partition hash functions for dropped tables, 
covering the DROP TABLE failure reported in FLINK-39328.

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

With regards,
GitHub Actions via GitBox

Reply via email to