java.lang.LinkageError: loader constraint violation: loader (instance of orgapacheflinkutilChild

运行

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包里面就不存在此依赖，就不会造成冲突。