当前位置：网站首页>【Flink】Flink 设置检查点失败一次就报错 setTolerableCheckpointFailureNumber 不起作用

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

2022-07-17 09:26:00 【九师兄】

文章目录


在这里插入图片描述

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
原网站

版权声明
本文为[九师兄]所创，转载请带上原文链接，感谢
https://blog.csdn.net/qq_21383435/article/details/124716272

边栏推荐

猜你喜欢

随机推荐