当前位置：网站首页>[Flink] Flink will report an error if it fails to set checkpoints once. Setlerablecheckpointfailurenumber does not work

[Flink] Flink will report an error if it fails to set checkpoints once. Setlerablecheckpointfailurenumber does not work

2022-07-19 13:57:00 【Ninth senior brother】

List of articles


Insert picture description here

1. summary

Excuse me ,Flink How to make checkpoints fail , The task will stop immediately ？

Flink 1.14.4, I set the checkpoint to a nonexistent path , Checkpoint failed , But the task didn't stop .
How can I make a checkpoint failure cause a task to fail and stop ？

Tried RestartStrategies.noRestart, as well as setTolerableCheckpointFailureNum by 0, But it doesn't work

The corresponding code is as follows

Insert picture description here
Final solution ： -Drestart-strategy=none Just set this . Remove the relevant restart parameters

2. Source code analysis

The settings related to the detection point are CheckpointConfig in , When setting the checkpoint failure tolerance value , The smallest is 0.0 It means reporting an error after one failure 


 /** * Determines the threshold that we tolerance declined che
原网站

版权声明
本文为[Ninth senior brother]所创，转载请带上原文链接，感谢
https://yzsam.com/2022/200/202207170926309152.html

边栏推荐

猜你喜欢

随机推荐