GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/681
implement a simple session management
This pull request implements a rudimentary session management. Together
with the backtracking #640, this will enable users to successively submit jobs
to the cluster and access intermediate results. Session handling ensures that
the results are cleared eventually.
ExecutionGraphs are kept as long as
- no timeout occurred or
- the session has not been explicitly ended
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink session
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/681.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 #681
----
commit e403db9874b587042e3fa740afbf00c0825eb61b
Author: Maximilian Michels <m...@apache.org>
Date: 2015-05-13T15:06:47Z
implement a simple session management
This pull request implements a rudimentary session management. Together
with the backtracking #640, this will enable users to submit jobs to the
cluster and access intermediate results. Session handling ensures that the
results are cleared eventually.
ExecutionGraphs are kept as long as
- no timeout occurred or
- the session has not been explicitly ended
----
---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
