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)