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

flink-user | Lukas Kairies | 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 | Lukas Kairies
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
  2. 0

    An exception is thrown when the port number is omitted

    GitHub | 2 years ago | KMax
    rx.exceptions.OnErrorNotImplementedException: port out of range:-1
  3. 0

    [Redis] 2.2.0 broken because of the out of range port

    GitHub | 3 years ago | jfarcand
    java.lang.IllegalArgumentException: port out of range:-1
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Get Fails for Abs URI When Port Not Specified Explicitly

    GitHub | 2 years ago | pete-experimenter
    java.lang.IllegalArgumentException: port out of range:-1
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.lang.IllegalArgumentException

    port out of range:-1

    at java.net.InetSocketAddress.checkPort()
  2. Java RT
    InetSocketAddress.<init>
    1. java.net.InetSocketAddress.checkPort(InetSocketAddress.java:143)
    2. java.net.InetSocketAddress.<init>(InetSocketAddress.java:224)
    2 frames
  3. org.xtreemfs.common
    XtreemFSFileSystem.initialize
    1. org.xtreemfs.common.libxtreemfs.Helper.stringToInetSocketAddress(Helper.java:82)
    2. org.xtreemfs.common.libxtreemfs.RPCCaller.getInetSocketAddressFromAddress(RPCCaller.java:301)
    3. org.xtreemfs.common.libxtreemfs.RPCCaller.syncCall(RPCCaller.java:88)
    4. org.xtreemfs.common.libxtreemfs.RPCCaller.syncCall(RPCCaller.java:49)
    5. org.xtreemfs.common.libxtreemfs.ClientImplementation.listVolumeNames(ClientImplementation.java:529)
    6. org.xtreemfs.common.clients.hadoop.XtreemFSFileSystem.initialize(XtreemFSFileSystem.java:164)
    6 frames
  4. flink-runtime
    HadoopFileSystem.initialize
    1. org.apache.flink.runtime.fs.hdfs.HadoopFileSystem.initialize(HadoopFileSystem.java:311)
    1 frame
  5. 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
  6. 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
  7. 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
  8. flink-runtime
    JobManager$$anonfun$receiveWithLogMessages$1.applyOrElse
    1. org.apache.flink.runtime.jobmanager.JobManager$$anonfun$receiveWithLogMessages$1.applyOrElse(JobManager.scala:172)
    1 frame
  9. 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
  10. org.apache.flink
    YarnJobManager$$anonfun$receiveYarnMessages$1.applyOrElse
    1. org.apache.flink.yarn.YarnJobManager$$anonfun$receiveYarnMessages$1.applyOrElse(YarnJobManager.scala:68)
    1 frame
  11. Scala
    PartialFunction$OrElse.apply
    1. scala.PartialFunction$OrElse.apply(PartialFunction.scala:162)
    1 frame
  12. 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
  13. Scala
    PartialFunction$class.applyOrElse
    1. scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
    1 frame
  14. flink-runtime
    ActorLogMessages$$anon$1.applyOrElse
    1. org.apache.flink.runtime.ActorLogMessages$$anon$1.applyOrElse(ActorLogMessages.scala:27)
    1 frame
  15. Akka Actor
    Actor$class.aroundReceive
    1. akka.actor.Actor$class.aroundReceive(Actor.scala:465)
    1 frame
  16. flink-runtime
    JobManager.aroundReceive
    1. org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:52)
    1 frame
  17. 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
  18. 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