Flink自定义MySQLSink批量写入出现死锁解决

一、错误日志

Cause: java.sql.SQLException: Lock wait timeout exceeded; try restarting transaction;

二、原因分析

　　在同一批次、同一事务中操作相同主键的数据，当提交事务时，就会出现死锁。

三、解决思路

　　去重处理，将同一批次的数据进行去重处理，保证同一批次提交数据中，不会操作多条主键相同的数据，这样事务就能完整提交，也就不会操作死锁。