0

Flink job submission

#  ./bin/flink run -m 10.0.2.4:6123 /storage/flink-1.10.0/examples/streaming/WordCount.jar --input /storage/flink-1.10.0/test.txt --output /storage/flink-1.10.0/test01.txt


------------------------------------------------------------
 The program finished with the following exception:

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.

$ ./bin/flink run -m 10.0.2.4:6123  /streaming/mvn-flinkstreaming-scala/mvn-flinkstreaming-scala-1.0.jar
Stream processing!!!!!!!!!!!!!!!!!
org.apache.flink.streaming.api.datastream.DataStreamSink@40ef3420

------------------------------------------------------------
 The program finished with the following exception:
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.

how to troubleshoot this issue, I have tried with the example job and a sample streaming job, getting the same error for both the jar files.

Improve this question
3
  • @David Anderson please have a look at this issue. Commented Mar 19, 2020 at 4:41
  • @kopaka please have a look at this issue. Commented Mar 19, 2020 at 4:42
  • Need to revalidate my cluster configuration and job manager IP address on the task manger node as well. Commented Mar 19, 2020 at 11:05
Related questions
2
Apache Flink InvocationTargetException: Job execution failed. Connection timed out
0
Flink Streaming Job is Failed Automatically
0
Flink job crashes after second submit
Load 7 more related questions Show fewer related questions

0

Reset to default

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge you have read our privacy policy.

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.