Aljoscha Krettek created FLINK-17766:
----------------------------------------
Summary: Use checkpoint lock instead of fine-grained locking in
Kafka AbstractFetcher
Key: FLINK-17766
URL: https://issues.apache.org/jira/browse/FLINK-17766
Project: Flink
Issue Type: Sub-task
Components: Connectors / Kafka
Reporter: Aljoscha Krettek
Assignee: Aljoscha Krettek
Fix For: 1.11.0
In {{emitRecordsWithTimestamps()}}, we are currently locking on the partition
state object itself to prevent concurrent access (and to make sure that changes
are visible across threads). However, after recent changes (FLINK-17307) we
hold the checkpoint lock for emitting the whole "bundle" of records from Kafka.
We can now also just use the checkpoint lock in the periodic emitter callback
and then don't need the fine-grained locking on the state for record emission.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
