Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[FLINK-4199] Fix misleading CLI messages and return execution result for interactive blocking execution #2264

Closed
wants to merge 3 commits into from

Conversation

mxm
Copy link
Contributor

@mxm mxm commented Jul 18, 2016

OLD

Cluster retrieved: Standalone cluster with JobManager at localhost/127.0.0.1:6123
Using address localhost:6123 to connect to JobManager.
JobManager web interface address http://localhost:8081
Starting execution of program
Submitting job with JobID: 9c7120e5cc55b2a9157a7e2bc5a12c9d. Waiting for job completion.
org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Communication with JobManager failed: Lost connection to the JobManager.
Job has been submitted with JobID 9c7120e5cc55b2a9157a7e2bc5a12c9d

NEW

Cluster configuration: Standalone cluster with JobManager at localhost/127.0.0.1:6123
Using address localhost:6123 to connect to JobManager.
JobManager web interface address http://localhost:8081
Starting execution of program
Executing WordCount example with default input data set.
Use --input to specify file input.
Printing result to stdout. Use --output to specify output path.
Submitting job with JobID: 20d070cf6a4289df4e5045c9c52cc47b. Waiting for job completion.

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

org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Communication with JobManager failed: Lost connection to the JobManager.

OLD

Cluster retrieved: Standalone cluster with JobManager at localhost/127.0.0.1:6123
Using address localhost:6123 to connect to JobManager.
JobManager web interface address http://localhost:8081
Starting execution of program
Submitting job with JobID: 477429b836247909dd428a6cba5b923b. Waiting for job completion.
07/12/2016 16:18:52 Job execution switched to status RUNNING.
07/12/2016 16:18:52 Source: Socket Stream -> Sink: Unnamed(1/1) switched to SCHEDULED
07/12/2016 16:18:52 Source: Socket Stream -> Sink: Unnamed(1/1) switched to DEPLOYING
07/12/2016 16:18:52 Source: Socket Stream -> Sink: Unnamed(1/1) switched to RUNNING
07/12/2016 16:18:58 Source: Socket Stream -> Sink: Unnamed(1/1) switched to FINISHED
07/12/2016 16:18:58 Job execution switched to status FINISHED.
Job has been submitted with JobID 477429b836247909dd428a6cba5b923b

NEW

Cluster configuration: Standalone cluster with JobManager at localhost/127.0.0.1:6123
Using address localhost:6123 to connect to JobManager.
JobManager web interface address http://localhost:8081
Starting execution of program
Executing WordCount example with default input data set.
Use --input to specify file input.
Printing result to stdout. Use --output to specify output path.
Submitting job with JobID: a56b184080d9755d3f2d40c7d9092b31. Waiting for job completion.
07/18/2016 16:42:23 Job execution switched to status RUNNING.
07/18/2016 16:42:23 Source: Collection Source -> Flat Map(1/1) switched to SCHEDULED 
07/18/2016 16:42:23 Source: Collection Source -> Flat Map(1/1) switched to DEPLOYING 
07/18/2016 16:42:23 Keyed Aggregation -> Sink: Unnamed(1/1) switched to SCHEDULED 
07/18/2016 16:42:23 Keyed Aggregation -> Sink: Unnamed(1/1) switched to DEPLOYING 
07/18/2016 16:42:23 Keyed Aggregation -> Sink: Unnamed(1/1) switched to RUNNING 
07/18/2016 16:42:23 Source: Collection Source -> Flat Map(1/1) switched to RUNNING 
07/18/2016 16:42:23 Source: Collection Source -> Flat Map(1/1) switched to FINISHED 
07/18/2016 16:42:23 Keyed Aggregation -> Sink: Unnamed(1/1) switched to FINISHED 
07/18/2016 16:42:23 Job execution switched to status FINISHED.
Program execution finished
Job with JobID a56b184080d9755d3f2d40c7d9092b31 has finished.
Job Runtime: 25 ms

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants