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.
