`org.apache.flink.table.data.util.DataFormatConverters$RowConverter` This class is in the flink-table-runtime package. Can you confirm if this package exists in your cluster ?
Best, Feng On Fri, Sep 6, 2024 at 11:47 AM Taher Koitawala <taher...@gmail.com> wrote: > Thank you, I tried with the new libraries you suggested. i am using flink > 1.18 and java 11 > > <dependency> > <groupId>org.apache.iceberg</groupId> > <artifactId>iceberg-flink</artifactId> > <version>1.6.1</version> > </dependency> > <!-- > https://mvnrepository.com/artifact/org.apache.iceberg/iceberg-flink-runtime > --> > <!-- > > https://mvnrepository.com/artifact/org.apache.iceberg/iceberg-flink-runtime-1.18 > --> > <dependency> > <groupId>org.apache.iceberg</groupId> > <artifactId>iceberg-flink-runtime-1.18</artifactId> > <version>1.6.1</version> > </dependency> > > I get the same error. > > Exception in thread "main" java.lang.NoClassDefFoundError: > org/apache/flink/table/data/util/DataFormatConverters$RowConverter > at org.apache.iceberg.flink.sink.FlinkSink.forRow(FlinkSink.java:115) > at org.example.Main.flinkProcessing(Main.java:96) > at org.example.Main.main(Main.java:35) > Caused by: java.lang.ClassNotFoundException: > org.apache.flink.table.data.util.DataFormatConverters$RowConverter > at > > java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:581) > at > > java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:178) > at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:527) > ... 3 more > > On Thu, Sep 5, 2024 at 10:46 PM Feng Jin <jinfeng1...@gmail.com> wrote: > > > Hi, Taher > > > > The version of iceberg connector you are using is not compatible with > Flink > > 1.18, you should use > > > > > https://mvnrepository.com/artifact/org.apache.iceberg/iceberg-flink-runtime-1.18 > > > > > > Best, > > Feng > > > > > > > > On Thu, Sep 5, 2024 at 9:21 PM Taher Koitawala <taher...@gmail.com> > wrote: > > > > > Hi All, > > > I am using flink 1.18.1 with iceberg. > > > > > > I get the following errors > > > > > > Exception in thread "main" java.lang.NoClassDefFoundError: > > > org/apache/flink/table/data/util/DataFormatConverters$RowConverter > > > at org.apache.iceberg.flink.sink.FlinkSink.forRow(FlinkSink.java:105) > > > at org.example.Main.flinkProcessing(Main.java:95) > > > at org.example.Main.main(Main.java:35) > > > Caused by: java.lang.ClassNotFoundException: > > > org.apache.flink.table.data.util.DataFormatConverters$RowConverter > > > at > > > > > > > > > java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:581) > > > at > > > > > > > > > java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:178) > > > at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:527) > > > ... 3 more > > > > > > > > > > > > I have already added these to the pom. What am i doing wrong? > > > > > > <dependency> > > > <groupId>org.apache.iceberg</groupId> > > > <artifactId>iceberg-flink</artifactId> > > > <version>1.6.1</version> > > > </dependency> > > > <!-- > > > > > > https://mvnrepository.com/artifact/org.apache.iceberg/iceberg-flink-runtime > > > --> > > > <dependency> > > > <groupId>org.apache.iceberg</groupId> > > > <artifactId>iceberg-flink-runtime</artifactId> > > > <version>0.12.1</version> > > > </dependency> > > > <!-- > > > https://mvnrepository.com/artifact/org.apache.flink/flink-table-common > > --> > > > <dependency> > > > <groupId>org.apache.flink</groupId> > > > <artifactId>flink-table-common</artifactId> > > > <version>1.18.1</version> > > > </dependency> > > > > > >
