linqigeng created FLINK-36619:
---------------------------------
Summary: Downstream lost the CreateTableEvent when tables were
removed and then re-added
Key: FLINK-36619
URL: https://issues.apache.org/jira/browse/FLINK-36619
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.2.0
Reporter: linqigeng
Attachments: image-2024-10-29-11-52-41-353.png
If some tables are removed from the `tables` parameter and then re-added, the
`CreateTableEvent` will be ignored and not sent to downstream.
This way to reproduce:
# set tables: test_db.\.*,test_db2.\.*
# remove `test_db2.\.*` from `tables` and restart pipeline job
# re-add `test_db2.\.*` to `tables` and restart pipeline job
!image-2024-10-29-11-52-41-353.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
