Tzu-Li (Gordon) Tai created FLINK-4753: ------------------------------------------
Summary: Kafka 0.8 connector's Periodic Offset Committer should synchronize on checkpoint lock Key: FLINK-4753 URL: https://issues.apache.org/jira/browse/FLINK-4753 Project: Flink Issue Type: Bug Components: Kafka Connector Reporter: Tzu-Li (Gordon) Tai Assignee: Tzu-Li (Gordon) Tai Fix For: 1.2.0 The {{PeriodicOffsetCommitter}} doesn't synchronize on the checkpoint lock when creating a copy of the partition offsets in the current state. I propose to pass the checkpoint lock into{{PeriodicOffsetCommitter}}, and let {{PeriodicOffsetCommitter}} use {{Kafka08Fetcher#snapshotCurrentState()}} to make the current state copy. -- This message was sent by Atlassian JIRA (v6.3.4#6332)