[
https://issues.apache.org/jira/browse/FLINK-36619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqigeng updated FLINK-36619:
------------------------------
Description:
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` to `{*}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!
was:
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` to `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!
> 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
> Priority: Major
> Attachments: image-2024-10-29-11-52-41-353.png,
> image-2024-10-29-12-04-26-718.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` to `{*}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)
