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)
