You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by mxm <gi...@git.apache.org> on 2016/07/18 15:27:38 UTC
[GitHub] flink pull request #2264: [FLINK-4199] Fix misleading CLI messages and retur...
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 <mx...@apache.org>
Date: 2016-07-18T13:41:12Z
save JobExecutionResult for interactive executions
commit 93045337bfe61287c42b62154d4e42aa44fc6f98
Author: Maximilian Michels <mx...@apache.org>
Date: 2016-07-18T13:41:45Z
only print Collection size in accumulator results
commit 5d26f43e8ca345d905ed63e20900efe9f09ef7d4
Author: Maximilian Michels <mx...@apache.org>
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request #2264: [FLINK-4199] Fix misleading CLI messages and retur...
Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2264
---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---