开发者社区> 问答> 正文

可以要求flink失败重启时 必须正常从checkpoint恢复,否则就重启失败吗?

flink任务失败重启时, flink last checkpoint 失败但任务仍然正常重启,导致 state 重启前后不一致,如题,可以要求flink失败重启时 必须正常从checkpoint恢复,否则就重启失败吗?

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

展开
收起
游客nnqbtnagn7h6s 2021-12-06 19:45:18 837 0
1 条回答
写回答
取消 提交回答
  • 可以通过以下方法设置从checkpoint恢复失败则启动失败 StreamExecutionEnvironment.getCheckpointConfig().setFailOnCheckpointingErrors(true); /** * Sets the expected behaviour for tasks in case that they encounter an error in their checkpointing procedure. * If this is set to true, the task will fail on checkpointing error. If this is set to false, the task will only * decline a the checkpoint and continue running. The default is true. */ public void setFailOnCheckpointingErrors(boolean failOnCheckpointingErrors) { this.failOnCheckpointingErrors = failOnCheckpointingErrors; }

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

    2021-12-06 21:17:10
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载