Iceberg v0.11 or v0.12 not capable with flink v1.13.x. L. C. Hsieh <vii...@apache.org> 于2021年8月21日周六 下午3:52写道：
> Hi, I'm testing using Flink to write Iceberg table. I run Flink native K8S > cluster locally and submit a simple Java program that writes out Iceberg > table (https://github.com/spancer/flink-iceberg-demo). But got an > exception: > > java.lang.NoClassDefFoundError: org/apache/hadoop/conf/Configuration at > org.apache.iceberg.flink.FlinkCatalogFactory.clusterHadoopConf(FlinkCatalogFactory.java:148) > at > org.apache.iceberg.flink.TableLoader.fromHadoopTable(TableLoader.java:49) > at > com.coomia.iceberg.test.IcebergReadWriteTest.main(IcebergReadWriteTest.java:89) > > The uploaded is a fat jar. I also checked the uploaded application jar. It > has the Configuration class. So I don't know what is wrong there. Any idea > or suggestion? Thanks. >
