Yanquan Lv created FLINK-38279:
----------------------------------
Summary: Failed to restore job when using MySQL Source with
scan.startup.mode=snapshot in streaming mode
Key: FLINK-38279
URL: https://issues.apache.org/jira/browse/FLINK-38279
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.4.0
Reporter: Yanquan Lv
When I use MySQL Source with scan.startup.mode=snapshot in streaming mode, I
try to restart a job from savepoint, however, an unexpected exception was
thrown:
{code:java}
ERROR
org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator
[] - Failed to reset the coordinator to checkpoint and
start.java.lang.UnsupportedOperationException: Unsupported restored
PendingSplitsState: SnapshotPendingSplitsState{remainingTables= {code}
This hinders me from recovering from the state.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)