You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/18 09:43:00 UTC

[jira] [Comment Edited] (FLINK-4808) Allow skipping failed checkpoints

    [ https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209082#comment-16209082 ] 

Till Rohrmann edited comment on FLINK-4808 at 10/18/17 9:42 AM:
----------------------------------------------------------------

Is this truly a blocker for 1.4? I would actually downgrade it to major. If we get it in for 1.4 then it's great, if not then we'll include in the next release.


was (Author: till.rohrmann):
Is this truly a blocker for 1.4? I would actually downgrade it to major. If we get it in for 1.4 then it's great, if not then we'll include in the next release. The same happened when we released 1.3.

> Allow skipping failed checkpoints
> ---------------------------------
>
>                 Key: FLINK-4808
>                 URL: https://issues.apache.org/jira/browse/FLINK-4808
>             Project: Flink
>          Issue Type: New Feature
>          Components: State Backends, Checkpointing
>    Affects Versions: 1.1.2, 1.1.3
>            Reporter: Stephan Ewen
>            Priority: Blocker
>             Fix For: 1.4.0
>
>
> Currently, if Flink cannot complete a checkpoint, it results in a failure and recovery.
> To make the impact of less stable storage infrastructure on the performance of Flink less severe, Flink should be able to tolerate a certain number of failed checkpoints and simply keep executing.
> This should be controllable via a parameter, for example:
> {code}
> env.getCheckpointConfig().setAllowedFailedCheckpoints(3);
> {code}
> A value of {{-1}} could indicate an infinite number of checkpoint failures tolerated by Flink.
> The default value should still be {{0}}, to keep compatibility with the existing behavior.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)