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

可以通过以下方法设置从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邮件归档