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)