[jira] [Created] (FLINK-13204) The subscribedPartitionStates should be thread safe.

[Shang Yuanchun (Jira)]

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)