Jiangjie Qin created FLINK-13204:
------------------------------------
Summary: The subscribedPartitionStates should be thread safe.
Key: FLINK-13204
URL: https://issues.apache.org/jira/browse/FLINK-13204
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.8.0
Reporter: Jiangjie Qin
The \{{subscribedPartitionState}} should be thread safe. This variable may be
modified by the partition discoverer thread while being read by the main
thread. So when subscribed partition changes (e.g. partition expansion, new
topic matching the pattern is created), a \{{ConcurrentModificationException}}
may be thrown.
The fix is to use the set from a {{ConcurrentHashMap}} instead of a \{{List}}
for \{{subscribedPartitionState}}.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
