[jira] [Created] (FLINK-22267) Savepoint an application for source of upsert-kafka, then restart the application from the savepoint, state not be recovered.

[Shang Yuanchun (Jira)]

Carl created FLINK-22267:
----------------------------

             Summary: Savepoint an application for source of upsert-kafka, then restart the application from the savepoint, state not be recovered.  
                 Key: FLINK-22267
                 URL: https://issues.apache.org/jira/browse/FLINK-22267
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
    Affects Versions: 1.12.2
            Reporter: Carl
         Attachments: image-2021-04-14-11-17-00-207.png

My operation is as follows：

1. Savepoint an application for source of upsert-kafka

2. Delete the upsert Kafka topic data

3. restart the application from the savepoint

4. Log shows that the offset has been restored, but the state has not been restored

What I want to confirm is that restart from savepoint in the source upsert-kafka application not restore the state from savepoint state but restore the state from earliest offset kafka message?

If so, why reset offset：

!image-2021-04-14-11-17-00-207.png!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)