Sorry..the error was caused by the fact that I've moved the table jar only
on the job manager machine.
After copying the jar from opt to lib in all the other TM machines the job
was able to continue!
Best,
Flavio
On Thu, Sep 14, 2017 at 6:56 PM, Flavio Pompermaier
wrote:
> Hi to all,
> I've tes
Hi to all,
I've tested my Flink 1.3.1 on my local machine and everything was fine.
So I've tried to run it on the cluster but I've got the following weird
exception (I've already moved flink-table_2.10-1.3.1.jar from opt to lib):
Caused by: java.lang.RuntimeException: The initialization of the
Da
