[FLINK-20544] ConcurrentModificationException when writing to hive and fail over happened

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.11.1
• Component/s: Connectors / FileSystem, Connectors / Hive, Table SQL / Ecosystem
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: zhuxiaoshang
• Created: 09/Dec/20 06:59
• Updated: 14/Dec/21 10:39

Description

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

Maybe using thread safe Map is better choice.