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)
