flink 1.13.6 加 flink cdc 2.4报这个错误其实这个在flink cdc2.3的时候就遇到过了我想问一下,除了重新编译flinkcdc 2.4把他换成guava18,还有其他解决办法吗?
您遇到的问题是由于 Flink CDC 2.4 使用了较新版本的 Guava(Google 的 Java 工具库)导致的。具体来说,Flink CDC 2.4 使用的 Guava 版本可能与您当前使用的 Flink 版本不兼容,导致出现了 NoClassDefFoundError 异常。
除了重新编译 Flink CDC 2.4,将其中的 Guava 版本改为与您当前使用的 Flink 版本兼容的版本之外,还可以考虑以下几个解决方法:
1. 使用 Flink CDC 2.3:如果您之前在 Flink CDC 2.3 版本中遇到了相同的问题,并且在 Flink CDC 2.3 中已经解决了这个问题,可以考虑回退到 Flink CDC 2.3 版本,以避免这个问题的出现。
2. 更新 Flink 版本:尝试升级到 Flink 1.14 及以上版本,以便与 Flink CDC 2.4 中使用的 Guava 版本兼容。这样可以避免 Guava 版本冲突的问题。
3. 排除 Guava 冲突:如果无法更改 Flink 版本或者重新编译 Flink CDC 2.4,可以尝试排除 Guava 冲突。具体来说,可以将 Flink CDC 2.4 中使用的 Guava 版本排除掉,使用 Flink 自带的 Guava 版本。您可以通过修改 Maven 或者 Gradle 的依赖来实现排除。
需要注意的是,根据具体情况选择适合您的解决方法。如果您选择重新编译 Flink CDC 2.4,请确保将其中的 Guava 版本改为与您当前使用的 Flink 版本兼容的版本。另外,升级 Flink 版本或者排除 Guava 冲突时,也需要进行充分的测试和评估,以确保系统的稳定性和正确性。
总之,针对您遇到的问题,除了重新编译 Flink CDC 2.4,还可以考虑回退到 Flink CDC 2.3、更新 Flink 版本或者排除 Guava 冲突等解决方法。请根据具体情况选择适合您的解决方案。
是由于 Flink CDC 2.4 使用了较新版本的 Guava(Google 的 Java 工具库)导致的问题。具体来说,Flink CDC 2.4 使用的 Guava 版本可能与您当前的 Flink 版本不兼容,导致出现了 NoClassDefFoundError 异常。
解决这个问题的方法,除了重新编译 Flink CDC 2.4,将其中的 Guava 版本改为与您当前 Flink 版本兼容的版本之外,还可以考虑以下几个方面:
使用 Flink CDC 2.3
如果您之前在 Flink CDC 2.3 版本中遇到了相同的问题,并且在 Flink CDC 2.3 中已经解决了这个问题,可以考虑回退到 Flink CDC 2.3 版本,以避免这个问题的出现。
更新 Flink 版本
另外一个解决方法是更新 Flink 版本,以便与 Flink CDC 2.4 中使用的 Guava 版本兼容。具体来说,可以尝试升级到 Flink 1.14 及以上版本,这些版本应该都可以与 Flink CDC 2.4 兼容。
排除 Guava 冲突
如果您无法更改 Flink 版本或者重新编译 Flink CDC 2.4,可以尝试排除 Guava 冲突。具体来说,可以将 Flink CDC 2.4 中使用的 Guava 版本排除掉,使用 Flink 自带的 Guava 版本。可以通过修改 Maven 或者 Gradle 依赖的方式进行排除。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。