你好,
可以检查一下 Flink 集群的 lib 目录下是不是同时存在 Kafka 相关的类,从异常来看应该是有类冲突。
--
Best Regards,
Qingsheng Ren
Email: renqs...@gmail.com
On Oct 28, 2021, 10:44 AM +0800, casel.chen , wrote:
> flink作业提交报如下异常,请问root cause是什么?要怎么修复呢?
>
>
>
> Caused by: java.lang.LinkageError: loader constraint vi
flink作业提交报如下异常,请问root cause是什么?要怎么修复呢?
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
使用flink 1.12.1,作业依赖了flink-sql-connector-kafka (依赖kafka-client 2.4.1)
和一个消费阿里dts应用的connector(该connector依赖kafka-client
1.0.0),出现下面的异常后我将flink-sql-connector-kafka依赖的kafka-client也换成了1.0.0,结果运行作业还是报同样的异常。请问这是jar包冲突造成的吗?应该怎么解决?
Caused by: java.lang.LinkageError: loader constraint violation: loader