Flink1.15.0——guava版本冲突解决
短信预约 -IT技能 免费直播动态提醒
问题描述:
使用Flink 1.15版本的时候,在本地运行没问题,但发布到集群会报ThreadFactoryBuilder这个类找不到的错误,报错如下:
java.lang.NoClassDefFoundError: org/apache/flink/shaded/guava18/com/google/common/util/concurrent/ThreadFactoryBuilder
报错原因:
flink 1.15 和 1.13 使用的 flink-shaded-guava 版本不一样,两个版本不兼容,需要修改 cdc 中的 flink-shaded-guava 版本为 flink 1.15 依赖的版本。
解决办法:
1. 添加以下依赖
org.apache.flink flink-shaded-guava 30.1.1-jre-15.0
- cdc版本改为2.3.0
com.ververica flink-connector-mysql-cdc 2.3.0
来源地址:https://blog.csdn.net/weixin_43777152/article/details/129012991
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341