综合分析补充题
一、Flink有哪些重启策略?各个重启策略如何配置?
详细了解,可参考本站Flink教程中"任务失败恢复"中的重启策略。
Flink支持不同的重启策略,可以控制在发生故障时如何重启新启动作业。
默认重启策略是通过Flink的配置文件设置的flink-conf.yaml。配置参数restart-strategy定义采用的策略。
如果未启用检查点,则使用“无重启”策略。如果激活了检查点并且尚未配置重启策略,则固定延迟策略将用于 Integer.MAX_VALUE重启尝试。
Flink支持的重启策略有五种:固定延迟重启策略、指数延迟策略、故障率重启策略、无重启策略、后备重启策略。
1.固定延迟重启策略
固定延迟重启策略是尝试给定次数重新启动作业。如果超过最大尝试次数,则作业失败。在两次连续重启尝试之间,会有一个固定的延迟等待时间。
通过在flink-conf.yaml中设置以下配置参数,默认启用该策略:
# fixed-delay:固定延迟策略 restart-strategy: fixed-delay # 尝试5次 ............
抱歉,只有登录会员才可浏览!会员登录