xuhaiLong created FLINK-36042: --------------------------------- Summary: newly added tables capture Key: FLINK-36042 URL: https://issues.apache.org/jira/browse/FLINK-36042 Project: Flink Issue Type: Bug Components: Flink CDC Reporter: xuhaiLong
CDC Pipeline dynamically adds tables, use this [pr|https://github.com/apache/flink-cdc/pull/3411], add the configuration item `SCAN_NEWLY_ADDED_TABLE_ENABLED: true`, # Submit mysql2sr job # Create a table in mysql # Capture ddl statements, but `org.apache.flink.cdc.connectors.mysql.debezium.reader.BinlogSplitReader#shouldEmit` will filter out the newly added table If restarted based on ck, the new table can be captured to complete table creation and data synchronization -- This message was sent by Atlassian Jira (v8.20.10#820010)