[
https://issues.apache.org/jira/browse/FLINK-36040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873105#comment-17873105
]
xuhaiLong commented on FLINK-36040:
-----------------------------------
Without restarting, the new table will be filtered [Newly added table captures
are filtered|https://issues.apache.org/jira/browse/FLINK-36042]
> mysql cdc pipeline recover error from ck
> ----------------------------------------
>
> Key: FLINK-36040
> URL: https://issues.apache.org/jira/browse/FLINK-36040
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.1.1
> Reporter: xuhaiLong
> Priority: Major
> Attachments: image-2024-08-13-11-16-03-924.png
>
>
> CDC Pipeline dynamically adds tables, use this
> [pr-3411|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
> # Restore the job from ck, and the error `Caused by:
> java.lang.IllegalStateException: Invalid assigner status {}
> [NEWLY_ADDED_ASSIGNING_FINISHED]` will appear
> # Adjust the ck interval to 5s, and after a successful checkpoint, the job
> will resume normal
>
> !image-2024-08-13-11-16-03-924.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
