GitHub user senorcarbone opened a pull request:
https://github.com/apache/flink/pull/551
[FLINK-1808] Send barrier requests only when the execution graph is running
This is a simple optimisation for the current StreamCheckpointCoordinator
that makes it skip barriers whent he execution graph is in any state other than
RUNNING.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbalassi/flink FLINK-1808
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/551.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 #551
----
commit dd8bbf7066af08b9e5af9d1ead75f596641cb1c0
Author: Paris Carbone <[email protected]>
Date: 2015-03-31T11:51:07Z
[FLINK-1808] [streaming] Send barrier requests only when the execution
graph is running
----
---
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.
---
