可以要求flink失败重启时 必须正常从checkpoint恢复，否则就重启失败吗？
flink任务失败重启时， flink last checkpoint 失败但任务仍然正常重启，导致 state 重启前后不一致，如题，可以要求flink失败重启时 必须正常从checkpoint恢复，否则就重启失败吗？
*来自志愿者整理的flink邮件归档
写回答
-
可以通过以下方法设置从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赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
