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

flink-user | Robert Metzger | 2 years ago
  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 | 12 months ago | Kashmar, Ali
    java.lang.Exception: Call to registerInputOutput() of invokable failed
  6. 0

    Re: Error due to Hadoop version mismatch

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

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    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
    16. Scala
      ForkJoinTask.doExec
      1. scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
      1 frame