Flink的task重启策略有哪些?如何配置?

提问者:帅平 问题分类:面试刷题
Flink的task重启策略有哪些?如何配置?
3 个回答
有你我就幸福
有你我就幸福
无重启策略:
作业直接失败,不尝试重启.
env.setRestartStrategy(RestartStrategies.noRestart());
发布于:3个月前 (02-06) IP属地:四川省
梦回往昔べ情难断
梦回往昔べ情难断
故障率重启:
故障率重启策略在故障发生之后重启作业,但是当故障率(每个时间间隔发生故障的次数)超过设定的限制时,作业会最终失败. 在连续的两次重启尝试之间,重启策略等待一段固定长度的时间. 即在restart-strategy.failure-rate.failure-rate-interval时间内失败超过 restart-strategy.failure-rate.max-failures-per-interval该值则失败.
//5分钟内,最大失败10次(第10次错误发生时,程序退出),而且每次失败10秒后再尝试重启 
env.setRestartStrategy(RestartStrategies.failureRateRestart(10,Time.minutes(5),Time.seconds(10)));
发布于:3个月前 (02-06) IP属地:四川省
宁愿短发披肩
宁愿短发披肩
固定延迟重启:
固定延迟重启策略是尝试给定次数重新启动作业。如果超过最大尝试次数,任务最终会失败。在两次连续的重启尝试之间,重启策略需要等待固定的时间。
//创建环境 
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); 
//打开checkpoint开关,默认是无限次重启的 
env.enableCheckpointing(3000); 
//设置最多尝试重启10次,任务失败5秒后开始执行重启操作 
env.setRestartStrategy(RestartStrategies.fixedDelayRestart(10,Time.seconds(5)));
发布于:3个月前 (02-06) IP属地:四川省
我来回答