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

flink-user | Timur Fayruzov | 8 months ago
  1. 0

    Integrate Flink with S3 on EMR cluster

    flink-user | 8 months 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-2555] Hadoop Input/Output Formats are unable to access secured HDFS clusters - ASF JIRA

    apache.org | 1 year ago
    org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Failed to submit job b319a28f62855917901cfb67c5457142 (Flink Java Job at Thu Aug 20 10:46:41 PDT 2015)
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Purpose of fs.hdfs.hadoopconf in flink-conf.yaml

    Stack Overflow | 5 months ago | coredump
    org.apache.flink.runtime.JobException: Creating the input splits caused an error: The given HDFS file URI (hdfs:///tmp/test-events.1468374669125) did not describe the HDFS NameNode. The attempt to use a default HDFS configuration, as specified in the 'fs.hdfs.hdfsdefault' or 'fs.hdfs.hdfssite' config parameter failed due to the following problem: Either no default file system was registered, or the provided configuration contains no valid authority component (fs.default.name or fs.defaultFS) describing the (hdfs namenode) host and port.

    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