运行
flink job用application模式运行时
flink run-application -t yarn-application /opt/flink/flink-job.jar
报错
Caused by: java.lang.LinkageError: loader constraint violation: loader (instance of org/apache/flink/util/ChildFirstClassLoader) previously initiated loading for a different type with name "org/apache/kafka/clients/consumer/ConsumerRecord"
解决
jar包依赖冲突,job中pom.xml中kafka-clients依赖与jobmanager中存在冲突,将
pom.xml中kafka-clients依赖设置限制范围,scope=provided
文章来源:https://www.toymoban.com/news/detail-753134.html
解释
一般默认为compile,其代表着编译环境、测试环境以及运行环境三种环境都可以有效,而provided仅代表着编译环境和测试环境有效,这样jar包里面就不存在此依赖,就不会造成冲突。文章来源地址https://www.toymoban.com/news/detail-753134.html
到了这里,关于java.lang.LinkageError: loader constraint violation: loader (instance of org/apache/flink/util/Child的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!