使用flinkcdc2.1.1读取MySQL数据报错

Wed, 19 Jan 2022 21:11:31 -0800 

环境：flink1.13.5，flinkcdc2.1.1，mysql5.7,idea2020
报错出现的时间没有规律，有可能很长时间不出现，有可能刚启动任务就报错，
报错如下：
Caused by: io.debezium.DebeziumException
    at 
io.debezium.connector.mysql.MySqlStreamingChangeEventSource.wrap(MySqlStreamingChangeEventSource.java:1146)
    ... 5 more
Caused by: java.lang.ArrayIndexOutOfBoundsException

已经添加如下配置：

properties.put("database.history.skip.unparseable.ddl","true");
properties.put("database.history.store.only.monitored.tables.ddl","true");

从 Windows 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>发送

回复