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成神之路。
共有 0 条评论