[jira] [Created] (FLINK-20544) ConcurrentModificationException when writing to hive and fail over happened

[Shang Yuanchun (Jira)]

zhuxiaoshang created FLINK-20544:
------------------------------------

             Summary: ConcurrentModificationException when writing to hive and fail over happened
                 Key: FLINK-20544
                 URL: https://issues.apache.org/jira/browse/FLINK-20544
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Hive, Table SQL / Ecosystem
    Affects Versions: 1.11.1
            Reporter: zhuxiaoshang
         Attachments: image-2020-12-09-14-57-22-862.png

A job which read from Kafka and write to hive.When the fail over happened.Got the following exception.

!image-2020-12-09-14-57-22-862.png!

Maybe using thread safe Map is better choice.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)