flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "1193216154" <1193216...@qq.com>
Subject 回复:Kafka库和Flink的反向类加载方法不兼容
Date Sat, 23 Nov 2019 09:16:51 GMT
parent&nbsp; first就是先加载环境的jar包,再加载用户的jar包(就是自己写的flink程序),children&nbsp;
first就是反过来。flink默认配置是chikdren&nbsp; first,建议不要动这个配置。而是检查一下自己的flink程序的pom依赖和flink&nbsp;
lib下面的jar包有没有冲突





---原始邮件---
发件人: "aven.wu"<danxieai258@163.com&gt;
发送时间: 2019年11月23日(星期六) 下午4:57
收件人: "user-zh@flink.apache.org"<user-zh@flink.apache.org&gt;;
主题: Kafka库和Flink的反向类加载方法不兼容


报错如下
cannot assign instance of org.apache.commons.collections.map.LinkedMap to field org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.pendingOffsetsToCommit
of type org.apache.commons.collections.map.LinkedMap in instance of org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer010

修改flink-conf.yaml
classloader.resolve-order: parent-first

哪位大佬能解释一下这个反向类加载是什么意思?

发送自Aven.wu
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message