FlinkFlink 设置检查点失败一次就报错 setTolerableCheckpointFailureNumber 不起作用

Posted 2022-07-18 九师兄

文章目录

• 1.概述
• 2.源码分析

1.概述

请问大家，Flink怎么让检查点失败，任务马上就停止呢？

Flink 1.14.4，我把检查点设置到了一个不存在的路径，检查点失败，但是任务没有停止。
请问怎么样能让检查点失败导致任务失败停止？

尝试过RestartStrategies.noRestart，以及setTolerableCheckpointFailureNum为0，但是都没有用

对应代码如下

最终解决 ： -Drestart-strategy=none 设置了这个就可以了。把相关重启参数去掉

2.源码分析

检测点相关的设置都在 CheckpointConfig 中，设置检查点失败容忍值的时候，最小都是0.0代表一次失败就报错

 /**
     * Determines the threshold that we tolerance declined che

暑期编程PK赛 得CSDN机械键盘等精美礼品！