org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
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 jobĀJul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at scala.concurrent.forkjoin.
ForkJoinPool.runWorker( ForkJoinPool.java:1979) Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at scala.concurrent.forkjoin.
ForkJoinWorkerThread.run( ForkJoinWorkerThread.java:107) Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: Caused by: org.apache.flink.runtime.
messages. FlinkJobNotFoundException: Could not find Flink job ( 0de3cb47d32dd25ba0375d97bfd073 87) Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at org.apache.flink.runtime.
dispatcher.Dispatcher. getJobMasterGatewayFuture( Dispatcher.java:693) Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at org.apache.flink.runtime.
dispatcher.Dispatcher. requestJob(Dispatcher.java: 459) Jul 06 16:51:26 flink-9edd15d7.bf2.tumblr.net docker[31171]: at sun.reflect.
GeneratedMethodAccessor48. invoke(Unknown Source) Is this known ?
Free forum by Nabble | Edit this page |