你是打包的时候自己打了 kafka 的依赖进去吗?看起来是应用里有一个 kafka 版本 A,接口 org.apache.kafka.common.serialization.Serializer 用应用 classloader 加载,然后 flink kafka connector 用集群 classloader 加载,继承自集群 classloader 里的 org.apache.kafka.common.serialization.Serializer 导致这个问题。
Best, tison. lp <973182...@qq.com> 于2021年1月27日周三 下午12:39写道: > 我写了一个 process > > function的demo,自定义source产生数据sink到kafka,然后发布到yarn集群运行,flink版本是1.11.2,采用application > Mode 部署,然后发现jobmanager-log报错: Failed to construct kafka producer;Caused by: > org.apache.kafka.common.KafkaException: class > org.apache.kafka.common.serialization.ByteArraySerializer is not an > instance > of org.apache.kafka.common.serialization.Serializer。 > 换了flink版本为1.12.1发现还是报这个错,后尝试采用per-job > > Mode部署发现是OK的。查资料发现是跟flink的类加载方式有关,即flink-conf.yml中的classloader.resolve-order参数,要将默认的 > > child-first改成parent-first,修改后确实ok了,但是有个疑惑,为啥要改这个参数呢,看了官方文档,一般不建议改这个参数的,他避免了使用flink内置的类加载器,而是使用APP自己的。 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/