GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2264
[FLINK-4199] Fix misleading CLI messages and return execution result for
interactive blocking execution
**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
```
---
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink FLINK-4199
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2264.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2264
----
commit de68ca28f6190dbbe90adf74447423549ea2c1c9
Author: Maximilian Michels <[email protected]>
Date: 2016-07-18T13:41:12Z
save JobExecutionResult for interactive executions
commit 93045337bfe61287c42b62154d4e42aa44fc6f98
Author: Maximilian Michels <[email protected]>
Date: 2016-07-18T13:41:45Z
only print Collection size in accumulator results
commit 5d26f43e8ca345d905ed63e20900efe9f09ef7d4
Author: Maximilian Michels <[email protected]>
Date: 2016-07-18T14:51:23Z
[FLINK-4199] change CLI message upon cluster retrieval
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
