[
https://issues.apache.org/jira/browse/FLINK-36040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873114#comment-17873114
]
Leonard Xu commented on FLINK-36040:
------------------------------------
[~xuhaiLong] Thanks for your reporting, [~loserwang1024] Would you like to
investigate this issue ?
> 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)
