[
https://issues.apache.org/jira/browse/FLINK-27195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen updated FLINK-27195:
-------------------------------
Description: 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 taken (e.g. discovered topic partitions). Therefore,
offsets to commit should be mutable. (was: 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.)
> 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.13.6, 1.14.4
> Reporter: Mason Chen
> Priority: Major
>
> 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 taken (e.g. discovered topic partitions). Therefore, offsets to
> commit should be mutable.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
