开发者社区> 问答> 正文

flink12同时使用引发类冲突问题

flink12同时使用flink-connector-kafka和flink-sql-connector-kafka会引发类冲突问题 在yarn中部署streaming程序,maven使用依赖    org.apache.flink   flink-connector-kafka-2.2_2.11   1.12.0     在flink的lib目录中有flink-sql-connector-kafka_2.11-1.12.0.jar,因为类冲突问题会引起在yarn中程序部署失败,flink默认类加载机制child-first,改为parent-first也样,类冲突问题可以参考http://apache-flink.147419.n8.nabble.com/Kafka-Consumer-td3475.html  org.apache.kafka.common.KafkaException: org.apache.flink.kafka.shaded.org.apache.kafka.common.serialization.ByteArrayDeserializer is not an instance of org.apache.kafka.common.serialization.Deserializer 

不会提ISSUE,还请社区修复*来自志愿者整理的flink邮件归档

展开
收起
CCCC 2021-12-02 14:58:50 1220 0
2 条回答
写回答
取消 提交回答
  • 现在好了吗?我1.16还存在这个问题的

    2023-05-06 20:56:16
    赞同 展开评论 打赏
  •   org.apache.flink   flink-connector-kafka-2.2_2.11   1.12.0 provided *来自志愿者整理的FLINK邮件归档

    2021-12-02 15:59:15
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载