You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Mason Chen (Jira)" <ji...@apache.org> on 2022/04/12 06:40:00 UTC

[jira] [Created] (FLINK-27195) KafkaSourceReader offsetsToCommit should be mutable

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)