[ https://issues.apache.org/jira/browse/FLINK-22267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu closed FLINK-22267. --------------------------- Resolution: Not A Problem > 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 > Priority: Major > 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)