云优惠
 云服务器优惠大全

首页    编程语言    Flink 支持的重启策略有哪些

Flink 支持的重启策略有哪些

创建时间:2020-08-13 14:50
浏览量:0
收藏

Flink支持不同的重启策略,可以控制在发生故障时如何重启新启动作业。

默认重启策略是通过Flink的配置文件设置的flink-conf.yaml。配置参数restart-strategy定义采用的策略。

如果未启用检查点,则使用“无重启”策略。如果激活了检查点并且尚未配置重启策略,则固定延迟策略将用于 Integer.MAX_VALUE重启尝试。

重启策略分为:固定延迟重启策略、故障率重启策略、无重启策略、后备重启策略。

申请阿里云服务时,可以使用2000元阿里云代金券,阿里云官网领取网址:https://www.aliyun.com/minisite/goods?userCode=2a7uv47d

1.固定延迟重启策略
固定延迟重启策略是尝试给定次数重新启动作业。如果超过最大尝试次数,则作业失败。在两次连续重启尝试之间,会有一个固定的延迟等待时间。

通过在flink-conf.yaml中配置参数:

fixed-delay:固定延迟策略

restart-strategy: fixed-delay

阿里云服务器1核2G低至82元/年,阿里云官活动网址:https://www.aliyun.com/minisite/goods?userCode=2a7uv47d 可以用20代金券,即102-20=82。

尝试5次,默认Integer.MAX_VALUE

restart-strategy.fixed-delay.attempts: 5

设置延迟时间10s,默认为 akka.ask.timeout时间

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

2.故障率重启策略
故障率重启策略在故障后重新作业,当设置的故障率(failure rate)超过每个时间间隔的故障时,作业最终失败。在两次连续重启尝试之间,重启策略延迟等待一段时间。

在flink-conf.yaml文件配置

设置重启策略为failure-rate

restart-strategy: failure-rate

失败作业之前的给定时间间隔内的最大重启次数,默认1

restart-strategy.failure-rate.max-failures-per-interval: 3

测量故障率的时间间隔。默认1min

restart-strategy.failure-rate.failure-rate-interval: 5min

两次连续重启尝试之间的延迟,默认akka.ask.timeout时间

restart-strategy.failure-rate.delay: 10s
在代码中设置:

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

// 3为最大失败次数;5min为测量的故障时间;10s为2次间的延迟时间
env.setRestartStrategy(RestartStrategies.failureRateRestart(3,Time.of(5, TimeUnit.MINUTES),Time.of(10, TimeUnit.SECONDS)));

3.无重启策略
作业直接失败,不尝试重启。

在flink-conf.yaml中配置:

restart-strategy: none
在代码中实现:

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
env.setRestartStrategy(RestartStrategies.noRestart());

4.后备重启策略
使用群集定义的重新启动策略。这对于启用检查点的流式传输程序很有帮助。默认情况下,如果没有定义其他重启策略,则选择固定延迟重启策略。

免费领取阿里云1888元代金券大礼包

 

阿里云新老用户均可领取!
自领取后:限时7天使用!

阿里云服务器2折优惠:低至293元/年

 

 

突发性能实例t5 1核1G:293元/年

突发性能实例t5 1核2G:459元/年

突发性能实例t5 2核4G:798元/年

共享型xn4实例1核1G内存:394元/年

共享型n4实例1核2G内存:653元/年

计算网络增强型实例2核4G内存:1566元/年

计算网络增强型实例4核8G内存:2991元/年

点此查看2折活动详情

阿里云高性能云服务器

 

 

网络增强型云服务器:2核4G ¥720元/年

高频应用云服务器:8核16G ¥4109元/年

本地SSD型云服务器:4核16G ¥6218.40元/年

大数据型云服务器:8核32G ¥11375.00元/年

GPU异构云服务器:16核40G ¥15563.00元/年

新用户满立减:每满1000立减50

 

1、到阿里云官网选购产品
2、加入到购物车
3、结算时立享满减

注意:新用户首次购买时必须先加到购物车,然后一起结算才享受此优惠。

腾讯云CVM云服务器22.07元起

 

 

腾讯云1核1G:22.07元/月、794.73元/3年

腾讯云2核2G:36.48元/月、1313.35元/3年

腾讯云2核4G:43.01元/月、1548.5元/3年

腾讯云4核8G:178.5元/月、6426元/3年