You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Jiangfei Liu (Jira)" <ji...@apache.org> on 2022/06/16 09:30:00 UTC

[jira] [Created] (FLINK-28093) Flink SQL Kafka Source Can Not Support Recovery On Checkpoint

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)