开发者社区> 问答> 正文

Checkpoint failed all the time

Checkpoint will fail for some reasons,

Is there a way to make checkpoint fail a certain number of times and then the job will fail automatically*来自志愿者整理的flink邮件归档

展开
收起
小阿矿 2021-12-08 10:54:49 1944 0
1 条回答
写回答
取消 提交回答
  • Sure, this feature has been implemented in FLINK-12364 [1], all you need do is set the tolerable checkpoint failure numbers via like

    env.getCheckpointConfig().setTolerableCheckpointFailureNumber(5);

    [1] https://issues.apache.org/jira/browse/FLINK-12364

    Best

    Yun Tang

    From: "sllence@aliyun.com.INVALID" sl...@aliyun.com.INVALID

    Reply-To: "user-zh@flink.apache.org" us...@flink.apache.org

    Date: Monday, November 4, 2019 at 12:02 PM

    To: "user-zh@flink.apache.org" us...@flink.apache.org

    Subject: Checkpoint failed all the time

    Checkpoint will fail for some reasons,

    Is there a way to make checkpoint fail a certain number of times and then the job will fail automatically

    *来自志愿者整理的flink邮件归档

    2021-12-08 14:56:20
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Using Hadoop to build a Data Quality Service for both real-time and batch data 立即下载
Time-evolving Graph Processing 立即下载
AliHB Real Time Cold data Backup 立即下载