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 <[email protected]> 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 <[email protected]> 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>
> >
>
