Flink的4种重启策略

妖狐艹你老母 2021-09-25 14:38 513阅读 0赞

如果checkpoint未启动，就会采用no restart策略；

如果启动了checkpoint机制，但是未指定重启策略的话，就会采用fixed-delay策略，重试Integer.MAX\_VALUE次。

分别是：

*  [Fixed Delay Restart Strategy][]
 *  [Failure Rate Restart Strategy][]
 *  [No Restart Strategy][]
 *  [Fallback Restart Strategy][]

1 固定间隔 (Fixed delay)

For example:

restart-strategy.fixed-delay.attempts: 3
    restart-strategy.fixed-delay.delay: 10 s

失败后，重启3次（每次重启间隔10s），如果第3次还是失败，则任务最终是失败，不再重启。

2 失败率 (Failure rate)

For example:

restart-strategy.failure-rate.max-failures-per-interval: 3
    restart-strategy.failure-rate.failure-rate-interval: 5 min
    restart-strategy.failure-rate.delay: 10 s

失败后，5分钟内重启3次（每次重启间隔10s），如果第3次还是失败，则任务最终是失败，不再重启。

3 无重启 (No restart)

第一次失败后就最终失败，不再重启。

4 Fallback(备用重启策略)

使用集群定义的重启策略。

参考：

[https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/restart\_strategies.html\#fallback-restart-strategy][Fallback Restart Strategy]

[Fixed Delay Restart Strategy]: https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/restart_strategies.html#fixed-delay-restart-strategy
[Failure Rate Restart Strategy]: https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/restart_strategies.html#failure-rate-restart-strategy
[No Restart Strategy]: https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/restart_strategies.html#no-restart-strategy
[Fallback Restart Strategy]: https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/restart_strategies.html#fallback-restart-strategy

发表评论取消回复

表情：

评论列表（有 0 条评论，513人围观）

还没有评论，来说两句吧...

相关阅读

相关 Flink的重启策略

Flink重启策略

忘是亡心i/ 2024年04月28日 13:04/ 0 赞/ 51 阅读

相关六、Flink 重启策略

*目录** 概述固定间隔失败率无重启策略实际代码演示 -------------------- 概述 * Flink支持不同的重启策略，以...

淡淡的烟草味﹌/ 2024年04月18日 23:09/ 0 赞/ 75 阅读

相关 Kubernetes---Pod重启策略

　　PodSpec中有一个restartPolicy 字段，可能的值为Always、OnFailure和Never。默认为Always。restartPolicy 适用于Pod

左手的ㄟ右手/ 2023年10月09日 10:48/ 0 赞/ 51 阅读

相关 Marathon上应用重启策略的设置

Marathon为运行中的应用提供了灵活的重启策略。当应用只有一个实例在运行，这时候重启的话，默认情况下Marathon会新起一个实例，在新实例重启完成之后，才会停掉原有实例，

╰+哭是因爲堅強的太久メ/ 2022年09月25日 07:29/ 0 赞/ 171 阅读

相关 Erlang supervisor重启策略

最近阅读了一下erlang的supervisor模块，自己写了一些简单的代码来区分不同重启策略的区别，这里记录一下。首先为了能够直观的观察，我把代码写成了一个applica

川长思鸟来/ 2022年08月14日 04:53/ 0 赞/ 291 阅读

相关重启OC4J .重启oacore

cd $INST\_TOP/admin/scripts cd admin cd scripts adoacorectl.sh stop a

ゝ一纸荒年。/ 2022年05月29日 07:20/ 0 赞/ 424 阅读

相关 Flink（十）Flink的重启策略

Flink的重启策略 Flink支持不同的重启策略，这些重启策略控制着job失败后如何重启。集群可以通过默认的重启策略来重启，这个默认的重启策略通常在未指定重启策略的情况

偏执的太偏执、/ 2022年02月04日 09:21/ 0 赞/ 442 阅读

相关 Flink重启策略

Flink重启策略 Flink支持不同的重启策略，可以控制在发生故障时如何重启新启动作业。默认重启策略是通过Flink的配置文件设置的`flink-conf.yaml

Love The Way You Lie/ 2021年12月24日 03:27/ 0 赞/ 303 阅读

相关 Flink重启策略

Flink重启策略 Flink支持不同的重启策略，可以控制在发生故障时如何重新启动作业。可以使用默认重新启动策略启动集群，该策略在未定义任何特定于作业的重新启动策略

迈不过友情╰/ 2021年11月16日 09:24/ 0 赞/ 380 阅读

相关 Flink的4种重启策略

如果checkpoint未启动，就会采用no restart策略；如果启动了checkpoint机制，但是未指定重启策略的话，就会采用fixed-delay策略，重试Int

妖狐艹你老母/ 2021年09月25日 14:38/ 0 赞/ 514 阅读