convert_to_null 这个是因为cdc2.1.0对mysql的链接字符串是8.0使用的导致的。MySql废弃了convertToNull这种写法,改为 CONVERT_TO_NULL写法,使用了8.0以上版本的JDBC driver for MySQL会出现该问题。
修改方式是修改cdc源码中mysql连接代码中的数据库连接字符串,并重新打包。可使用该cdc:flink-connector-mysql-cdc-2.1.0.jar (30.6 MB)
3赞
我现在用的mysql flink-cdc jar 是2.2.1版本 也是出现这个问题
mysql 连接字符串
?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=CTT
更改成
?characterEncoding=utf-8&useSSL=false&serverTimeZone=GMT+8
即可