Mason Chen created FLINK-27195:
----------------------------------
Summary: KafkaSourceReader offsetsToCommit should be mutable
Key: FLINK-27195
URL: https://issues.apache.org/jira/browse/FLINK-27195
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.14.4, 1.13.6
Reporter: Mason Chen
In the KafkaSourceReader, offsetsToCommit should be mutable. Currently, the
condition that splits is empty initializes the offsets to commit as an
immutable empty map. However, it is possible to have splits assigned after a
checkpoint is take (e.g. discovered topic partitions). Therefore, offsets to
commit should be mutable.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
