1.环境介绍
Flink1.17 + Flinkcdc 2.2.1
2.问题描述
使用Flink1.17 和 Flinkcdc 2.2.1环境进行数据加工,但是报以上错误,原因是版本不匹配,flinkcdc 2.2.1用的是guava18,但是flink1.17用的是guava30,导致冲突。
3.问题解决
添加flink-sql-connector-mysql-cdc依赖
<dependency>
<groupId>com.ververica</groupId>
<artifactId>flink-sql-connector-mysql-cdc</artifactId>
</dependency>
程序正常运行
具体原因咱也搞不明白,这个版本问题困扰了咱好长时间,网上查过各个版本的解决方法,都无效,特此记录。
4.引述
也尝试过 flinkcdc 2.4.2 版本以及更高的flinkcdc版本,都会报另一个错误。
标签:lang,google,版本,cdc,flink,util,flinkcdc,mysql,2.2 From: https://blog.csdn.net/m0_57592634/article/details/143951648这个问题我真的是醉醉的了,直到现在咱也没找到解决方案。虽然高版本的cdc都用了和flink1.17一样的guava30版本,但是debezium报缺少getJavaEncodingForMysqlCharSet方法的错误,从网上找了解决办法,新增了各个高版本的mysql依赖,都解决不了这个问题。
最后只能退而求其次,选择上述解决办法。