aint violation: loader
>>> (instance of org/apache/flink/util/ChildFirstClassLoader) previously
>>> initiated loading for a different type with name
>>> "org/apache/kafka/clients/consumer/ConsumerRecord"
>
>
>
>---
>Best,
>WuKong
>
t;> "org/apache/kafka/clients/consumer/ConsumerRecord"
---
Best,
WuKong
发件人： casel.chen
发送时间： 2021-11-08 14:38
收件人： user-zh
主题： Re:Re: 提交flink作业抛 java.lang.LinkageError
版本是一致的，都是1.12.5版本
在 2021-11-08 11:11:35，"Shuiqiang Chen" 写道：
>Hi,
>
>能检查下作业jar里 kafka cl
t;> "org/apache/kafka/clients/consumer/ConsumerRecord"
---
Best,
WuKong
发件人： casel.chen
发送时间： 2021-11-08 14:38
收件人： user-zh
主题： Re:Re: 提交flink作业抛 java.lang.LinkageError
版本是一致的，都是1.12.5版本
在 2021-11-08 11:11:35，"Shuiqiang Chen" 写道：
>Hi,
>
>能检查下作业jar里 kafka cl
t;> "org/apache/kafka/clients/consumer/ConsumerRecord"
---
Best,
WuKong
发件人： casel.chen
发送时间： 2021-11-08 14:38
收件人： user-zh
主题： Re:Re: 提交flink作业抛 java.lang.LinkageError
版本是一致的，都是1.12.5版本
在 2021-11-08 11:11:35，"Shuiqiang Chen" 写道：
>Hi,
>
>能检查下作业jar里 kafka cl
版本是一致的，都是1.12.5版本
在 2021-11-08 11:11:35，"Shuiqiang Chen" 写道：
>Hi,
>
>能检查下作业jar里 kafka client的版本和平台上的是否一致吗？
>
>casel.chen 于2021年11月5日周五 下午11:25写道：
>
>> 我在公司实时计算平台上提交了一个streaming api写的作业，结果抛如下异常。因为我们的实时计算平台是以flink
>> sql为主的，上面已经集成了flink-kafka-connector。而我提交的作业也是需要从kafka消费，所以将相同版本的flink kafka
>>
Hi,
能检查下作业jar里 kafka client的版本和平台上的是否一致吗？
casel.chen 于2021年11月5日周五 下午11:25写道：
> 我在公司实时计算平台上提交了一个streaming api写的作业，结果抛如下异常。因为我们的实时计算平台是以flink
> sql为主的，上面已经集成了flink-kafka-connector。而我提交的作业也是需要从kafka消费，所以将相同版本的flink kafka
> connector也打进了作业jar包内。请问是什么原因造成的，需要如何修复？谢谢！
>
>
> 2021-11-05 16:38:58 - [s
我在公司实时计算平台上提交了一个streaming api写的作业，结果抛如下异常。因为我们的实时计算平台是以flink
sql为主的，上面已经集成了flink-kafka-connector。而我提交的作业也是需要从kafka消费，所以将相同版本的flink kafka
connector也打进了作业jar包内。请问是什么原因造成的，需要如何修复？谢谢！
2021-11-05 16:38:58 - [submit-session-executor-6] ERROR
c.h.s.launcher.AbstractJobExecutor - -start job faile
