The UI shows the following and the JM goes into a convulsions trying to retrieve a jobiid as above.org.apache.flink.client.program. ProgramInvocationException: The main method caused an error. On Fri, Jul 6, 2018 at 4:53 PM, Vishal Santoshi <[hidden email]> wrote:If we submit a job through CLI and it has an error ( missing args and so on ) , the JM goes into convulsions. It seems it submits a job without fist validating and then goes into a loop trying to figure out the jobJul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at scala.concurrent.forkjoin.Fork
JoinPool.runWorker(ForkJoinPoo l.java:1979) Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at scala.concurrent.forkjoin.Fork
JoinWorkerThread.run(ForkJoinW orkerThread.java:107) Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: Caused by: org.apache.flink.runtime.messa
ges.FlinkJobNotFoundException: Could not find Flink job (0de3cb47d32dd25ba0375d97bfd07 387) Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at org.apache.flink.runtime.dispa
tcher.Dispatcher.getJobMasterG atewayFuture(Dispatcher.java: 693) Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at org.apache.flink.runtime.dispa
tcher.Dispatcher.requestJob( Dispatcher.java:459) Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at sun.reflect.GeneratedMethodAcc
essor48.invoke(Unknown Source) Is this known ?
Free forum by Nabble | Edit this page |