Hey,
Have you updated the versions both on the environment and the dependency on
the job?
>From my personal experience, 95 % of such issues is due to the mismatch
between Flink versions on the cluster you are using and Your job.
Best Regards,
Dom.
wt., 20 lis 2018 o 07:41 Steve Bistline
napisał
Hey all... upgrade from Flink 1.5.0 to 1.6.2 and for some reason cannot
figure out what I missed in setting up the new environment. I am gettin
this error:
java.lang.NoClassDefFoundError: Could not initialize class
org.apache.flink.kinesis.shaded.com.amazonaws.partitions.PartitionsLoader
