Hi Samya,
Were you able to get this resolved? Seeing the same issue here after upgrading
to Flink 1.9 from 1.6.
Thanks,
Thad
From: Andrey Zagrebin
Sent: Wednesday, July 3, 2019 9:09 AM
To: Haibo Sun
Cc: Patro, Samya ; user@flink.apache.org; Bari, Swapnil
Subject: Re: Could not load the nat
Upgrading to Flink 1.6.2 from 1.6.0 appears to fix this, after making sure each
job is writing checkpoints to a unique directory since the jobid's all match.
Thad Truman | Software Engineer | Neovest, Inc.
A:
T:
E:
1145 S 800 E, Ste 310 Orem, UT 84097
+1 801 900 2480
ttru...@neoves
uler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:284)
at
akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:236)
at java.lang.Thread.run(Thread.java:748)
Any ideas on how we can remediate this?
Thanks,
Thad Truman | Softwa
t.java:99)
~[flink-dist_2.11-1.6.1.jar:1.6.1]
... 8 more
When I launch and attach the docker image, job.jar exists in /opt/flink and
there is a symbolic link in /opt/flink/lib.
Any ideas as to why job.jar can't be found?
Our flink version is 1.6.1. We are using the flink-1.6.1-bin-sc
