Jonas Weile created FLINK-33466:
-----------------------------------
Summary: Bounded Kafka source never finishes after restore from
savepoint
Key: FLINK-33466
URL: https://issues.apache.org/jira/browse/FLINK-33466
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka, Runtime / Checkpointing
Affects Versions: 1.17.1
Reporter: Jonas Weile
When setting up a bounded Kafka source with the OffsetsInitializer.latest(), if
the job is restored from a savepoint before the source has finished, then the
Kafka source will never transition to a finished state.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
