从Flink重启策略机制能学习到什么？

最近在学习Flink &＃xff0c;在看到Flink的重启策略机制时感觉这个设计很好。

第一个是固定延迟重启

间隔1分钟&＃xff0c;尝试三次&＃xff0c;这是我们经常用到的。

但是这个方法有一个缺点&＃xff0c;就是次数和间隔不好确定

第二个是按照失败率重启

十分钟之内每间隔1分钟重启一次&＃xff0c;10分钟最多尝试3次&＃xff0c;每次间隔1分钟.

(⊙o⊙)… 这种设计就比较优雅.

// 3. 重启策略配置// 固定延迟重启env.setRestartStrategy(RestartStrategies.fixedDelayRestart(3, 10000L));// 失败率重启env.setRestartStrategy(RestartStrategies.failureRateRestart(3, Time.minutes(10), Time.minutes(1)));