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)

Reply via email to