xuhaiLong created FLINK-36040:
---------------------------------
Summary: 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
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)
