Jiangfei Liu created FLINK-28093:
------------------------------------

             Summary: Flink SQL Kafka Source Can Not Support Recovery On 
Checkpoint
                 Key: FLINK-28093
                 URL: https://issues.apache.org/jira/browse/FLINK-28093
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka, Table SQL / API
    Affects Versions: 1.14.4, 1.14.3, 1.13.5
            Reporter: Jiangfei Liu
         Attachments: s.png

1.Flink SQL Kafka Source Consumer Topic Msg,And Do Checkpoint

2.Stop Flink Task

3.Write Data to Topic

4.Recovery On Checkpoint

5.Flink Job Can Not Recovery On Checkpoint And Dont Continued consumption On 
Checkpoint State



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

Reply via email to