org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Failed to submit job fc13373d993539e647f164e12d82bf90 (WordCount Example)

flink-user | Timur Fayruzov | 1 year ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

    Integrate Flink with S3 on EMR cluster

    flink-user | 1 year ago | Timur Fayruzov
    org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Failed to submit job fc13373d993539e647f164e12d82bf90 (WordCount Example)
  2. 0

    [FLINK-2770] KafkaITCase.testConcurrentProducerConsumerTopology fails - ASF JIRA

    apache.org | 1 year ago
    org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Job execution failed.
  3. 0

    Flink program works from IDE but not from terminal

    Stack Overflow | 3 months ago | A.Vadillo
    org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Cannot initialize task 'CHAIN DataSource (at main(JobSource.java:49) (es.mypackage.flink.Sources.MyInputFormat)) -> Map (Map at main(JobSource.java:53))': Configuring the InputFormat (es.mypackage.flink.Sources.MyInputFormat@1f81aa00) failed: null
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. org.apache.flink.runtime.JobException

      Creating the input splits caused an error: org.apache.hadoop.conf.Configuration.addResource(Lorg/apache/hadoop/conf/Configuration;)V

      at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>()
    2. flink-runtime
      JobManager$$anonfun$handleMessage$1.applyOrElse
      1. org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:172)
      2. org.apache.flink.runtime.executiongraph.ExecutionGraph.attachJobGraph(ExecutionGraph.java:696)
      3. org.apache.flink.runtime.jobmanager.JobManager.org$apache$flink$runtime$jobmanager$JobManager$$submitJob(JobManager.scala:1023)
      4. org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1.applyOrElse(JobManager.scala:380)
      4 frames
    3. Scala
      AbstractPartialFunction.apply
      1. scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
      1 frame
    4. org.apache.flink
      YarnJobManager$$anonfun$handleYarnMessage$1.applyOrElse
      1. org.apache.flink.yarn.YarnJobManager$$anonfun$handleYarnMessage$1.applyOrElse(YarnJobManager.scala:153)
      1 frame
    5. Scala
      PartialFunction$OrElse.apply
      1. scala.PartialFunction$OrElse.apply(PartialFunction.scala:167)
      1 frame
    6. flink-runtime
      LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse
      1. org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:36)
      1 frame
    7. Scala
      AbstractPartialFunction.apply
      1. scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36)
      1 frame
    8. flink-runtime
      LogMessages$$anon$1.apply
      1. org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33)
      2. org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28)
      2 frames
    9. Scala
      PartialFunction$class.applyOrElse
      1. scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
      1 frame
    10. flink-runtime
      LogMessages$$anon$1.applyOrElse
      1. org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28)
      1 frame
    11. Akka Actor
      Actor$class.aroundReceive
      1. akka.actor.Actor$class.aroundReceive(Actor.scala:465)
      1 frame
    12. flink-runtime
      JobManager.aroundReceive
      1. org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:106)
      1 frame
    13. Akka Actor
      Mailbox.exec
      1. akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
      2. akka.actor.ActorCell.invoke(ActorCell.scala:487)
      3. akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
      4. akka.dispatch.Mailbox.run(Mailbox.scala:221)
      5. akka.dispatch.Mailbox.exec(Mailbox.scala:231)
      5 frames
    14. Scala
      ForkJoinWorkerThread.run
      1. scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
      2. scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
      3. scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
      4. scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
      4 frames