Loader.loadClass(BuiltinClassLoader.java:766)
at
java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:178)
Any help to know why this is happening and fix it would be much appreciated.
Many thanks,
Adesh DSilva
ble/factories/BulkReaderFormatFactory.java
>
>
> Best regards,
> Jing
>
> On Wed, Mar 2, 2022 at 6:34 PM Adesh Dsilva
> wrote:
>
> > Hi
> >
> > I am struggling to run my test Flink project with Table API
> >
&
Hi,
I wrote a simple program using Flink Table API.
There is a Table source reading from an avro file, after doing some operations
the result is stored using a sink csv table using `executeInsert()`
The program works fine and creates a csv file however the flink command does
not wait for job t
