java.lang.LinkageError: loader constraint violation: loader (instance of org/apache/flink/util/Child

运行

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

在这里插入图片描述

解释

一般默认为compile,其代表着编译环境、测试环境以及运行环境三种环境都可以有效,而provided仅代表着编译环境和测试环境有效,这样jar包里面就不存在此依赖,就不会造成冲突。

本文来自网络,不代表协通编程立场,如若转载,请注明出处:https://www.net2asp.com/3fc563014a.html