Iceberg x Flink java.lang.NoClassDefFoundError: org/apache/avro/Logical

问题描述 :
Flink SQL导入Iceberg时数据写入失败 打印日志时发现报错: java.lang.NoClassDefFoundError: org/apache/avro/Logical导致程序终止 double shift 查询的时候发现也是有的 iceberg-flink-runtime包里
原因分析:
maven管理jar包 处理依赖冲突时没有用iceberg-flink-runtime里的包 用插件查了下avro包 发现确实没有用iceberg-flink-runtime里的 而是用的hadoop-client中的 调换顺序 reimport / exclude 后 程序即可正常运行 (调换依赖顺序 reimport后的 冲突管理)

Iceberg x Flink java.lang.NoClassDefFoundError: org/apache/avro/Logical最先出现在Python成神之路

版权声明:
作者:dingding
链接:https://www.techfm.club/p/24864.html
来源:TechFM
文章版权归作者所有,未经允许请勿转载。

THE END
分享
二维码
< <上一篇
下一篇>>