有人知道flink和flinkcdc的jar冲突是那2个jar冲突吗?
我启动集群一直报这个错误?
根据您提供的截图,这个错误是由于Java.lang.Thread(Thread.java:180)中的concurrent.ScheduledThreadPoolExecutor的scheduleFutureTask方法抛出的异常引起的。具体来说,这个异常是由java.lang.NoClassDefFoundError引起的,原因是找不到ConcurrentLinkedQueue类。
要解决这个问题,您可以尝试以下方法:
Flink和Flink CDC的jar冲突可能是由于依赖的不同版本或者包引起的。例如,如果Flink集群已经存在某些jar包,如guava,然后在应用程序中又引入了这些相同的jar包,那么就可能会发生冲突。解决这种冲突的一种方法是确保应用程序和Flink集群使用一致的jar包版本。如果出现版本不一致的问题,可以尝试排除冲突的jar包,或者使用适当的依赖管理工具,如Maven或Gradle,来明确管理项目的依赖关系,以避免jar包冲突。此外,在开发和部署Flink应用时,通常会配合flinksql、kafka、mysql、hbase、cdc等一块使用,为避免jar包缺失、冲突,需要做好版本管理和配置。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。