Searched on Google with the first line of a JAVA stack trace?

We can recommend more relevant solutions and speed up debugging when you paste your entire stack trace with the exception message. Try a sample exception.

Recommended solutions based on your search

Solutions on the web

via flink-user by rafal green, 1 year ago
The program execution failed: Job execution failed.
via nabble.com by Unknown author, 1 year ago
The program execution failed: Job execution failed.
via Stack Overflow by rafal green
, 1 year ago
The program execution failed: Job execution failed.
via Stack Overflow by Humberto Moura
, 1 year ago
The program execution failed: Communication with JobManager failed: Lost connection to the JobManager.
via flink-user by Timur Fayruzov, 1 year ago
The program execution failed: Failed to submit job fc13373d993539e647f164e12d82bf90 (WordCount Example)
via flink-user by Lydia Ickler, 2 years ago
The program execution failed: Cannot initialize task 'DataSink (CsvOutputFormat (path: hdfs://grips2:9000/users/Wordcount_1000s, delimiter: ))': Output directory could not be created.
org.apache.flink.runtime.client.JobExecutionException: Job
 execution failed.	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply$mcV$sp(JobManager.scala:807)	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:753)	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:753)	at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)	at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)	at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)	at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)	at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)	at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)	at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)