GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1537
[FLINK-3261] Allow Task to decline checkpoint request if not ready
Before, it could happen that a StreamingTask receives a Checkpoint
Trigger message while internally not being ready. The checkpoint
coordinator would then wait the specified timeout interval before
continuing. Now, tasks can signal that they are not ready and the
checkpoint coordinator will dicard a checkpoint for which is this the
case and trigger new checkpoints if necessary.
The newly triggered checkpoints will also release alignment locks in
streaming tasks that are still waiting for barriers from failed
checkpoints.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink checkpoint-coordinator-decline
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1537.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 #1537
----
commit c759e2a0a2a1310467c25d84912544abaf5ab29e
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Date: 2016-01-21T16:21:09Z
[FLINK-3261] Allow Task to decline checkpoint request if not ready
Before, it could happen that a StreamingTask receives a Checkpoint
Trigger message while internally not being ready. The checkpoint
coordinator would then wait the specified timeout interval before
continuing. Now, tasks can signal that they are not ready and the
checkpoint coordinator will dicard a checkpoint for which is this the
case and trigger new checkpoints if necessary.
The newly triggered checkpoints will also release alignment locks in
streaming tasks that are still waiting for barriers from failed
checkpoints.
----
---
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.
---
