org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.

flink-user | Stephan Ewen | 2 years 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

    Re: How to add jars to flink

    flink-user | 2 years ago | Robert Metzger
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
  2. 0

    Re: How to add jars to flink

    flink-user | 2 years ago | Stephan Ewen
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
  3. 0

    Re: How to add jars to flink

    flink-user | 2 years ago | Robert Metzger
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Error due to Hadoop version mismatch

    flink-dev | 1 year ago | Kashmar, Ali
    java.lang.Exception: Call to registerInputOutput() of invokable failed
  6. 0

    Re: Error due to Hadoop version mismatch

    flink-dev | 1 year ago | Robert Metzger
    java.lang.Exception: Call to registerInputOutput() of invokable failed

    Root Cause Analysis

    1. java.io.IOException

      The given file URI (xtreemfs:///result.txt) points to the HDFS NameNode at null, but the File System could not be initialized with that address: port out of range:-1

      at org.apache.flink.runtime.fs.hdfs.HadoopFileSystem.initialize()
    2. flink-runtime
      HadoopFileSystem.initialize
      1. org.apache.flink.runtime.fs.hdfs.HadoopFileSystem.initialize(HadoopFileSystem.java:325)
      1 frame
    3. flink-core
      FileOutputFormat.initializeGlobal
      1. org.apache.flink.core.fs.FileSystem.get(FileSystem.java:244)
      2. org.apache.flink.core.fs.Path.getFileSystem(Path.java:299)
      3. org.apache.flink.api.common.io.FileOutputFormat.initializeGlobal(FileOutputFormat.java:267)
      3 frames
    4. flink-runtime
      JobManager$$anonfun$receiveWithLogMessages$1$$anonfun$applyOrElse$5.apply
      1. org.apache.flink.runtime.jobgraph.OutputFormatVertex.initializeOnMaster(OutputFormatVertex.java:84)
      2. org.apache.flink.runtime.jobmanager.JobManager$$anonfun$receiveWithLogMessages$1$$anonfun$applyOrElse$5.apply(JobManager.scala:179)
      3. org.apache.flink.runtime.jobmanager.JobManager$$anonfun$receiveWithLogMessages$1$$anonfun$applyOrElse$5.apply(JobManager.scala:172)
      3 frames
    5. Scala
      AbstractIterable.foreach
      1. scala.collection.Iterator$class.foreach(Iterator.scala:727)
      2. scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
      3. scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
      4. scala.collection.AbstractIterable.foreach(Iterable.scala:54)
      4 frames
    6. flink-runtime
      JobManager$$anonfun$receiveWithLogMessages$1.applyOrElse
      1. org.apache.flink.runtime.jobmanager.JobManager$$anonfun$receiveWithLogMessages$1.applyOrElse(JobManager.scala:172)
      1 frame
    7. Scala
      AbstractPartialFunction$mcVL$sp.apply
      1. scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
      2. scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
      3. scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
      3 frames
    8. org.apache.flink
      YarnJobManager$$anonfun$receiveYarnMessages$1.applyOrElse
      1. org.apache.flink.yarn.YarnJobManager$$anonfun$receiveYarnMessages$1.applyOrElse(YarnJobManager.scala:68)
      1 frame
    9. Scala
      PartialFunction$OrElse.apply
      1. scala.PartialFunction$OrElse.apply(PartialFunction.scala:162)
      1 frame
    10. flink-runtime
      ActorLogMessages$$anon$1.apply
      1. org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:37)
      2. org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:27)
      2 frames
    11. Scala
      PartialFunction$class.applyOrElse
      1. scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
      1 frame
    12. flink-runtime
      ActorLogMessages$$anon$1.applyOrElse
      1. org.apache.flink.runtime.ActorLogMessages$$anon$1.applyOrElse(ActorLogMessages.scala:27)
      1 frame
    13. Akka Actor
      Actor$class.aroundReceive
      1. akka.actor.Actor$class.aroundReceive(Actor.scala:465)
      1 frame
    14. flink-runtime
      JobManager.aroundReceive
      1. org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:52)
      1 frame
    15. 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