刷题刷出新高度，偷偷领先！偷偷领先！偷偷领先！ 关注我们，悄悄成为最优秀的自己！

面试题

如何处理 Flink 作业频繁重启问题 ？

使用微信搜索喵呜刷题，轻松应对面试！

答案：

分析&回答

Flink 实现了多种重启策略

  1. 固定延迟重启策略（Fixed Delay Restart Strategy）
  2. 故障率重启策略（Failure Rate Restart Strategy）
  3. 没有重启策略（No Restart Strategy）
  4. Fallback重启策略（Fallback Restart Strategy）

反思&扩展

  • Flink支持不同的重启策略，以在故障发生时控制作业如何重启
  • 默认的重启策略：如果没有启用 checkpointing，则使用无重启 (no restart) 策略。如果启用了 checkpointing，但没有配置重启策略，则使用固定间隔 (fixed-delay) 策略
  • 如果在工作提交时指定了一个重启策略，该策略会覆盖集群的默认策略默认的重启策略可以通过 Flink 的配置文件 flink-conf.yaml 指定。配置参数 restart-strategy 定义了哪个策略被使用。
  • 常用的重启：
    1. 策略固定间隔 (Fixed delay)
    2. 失败率 (Failure rate)
    3. 无重启 (No restart)
  • 重启策略可以在flink-conf.yaml中配置，表示全局的配置。也可以在应用代码中动态指定，会覆盖全局配置
创作类型：
原创

本文链接：如何处理 Flink 作业频繁重启问题 ？

版权声明：本站点所有文章除特别声明外，均采用 CC BY-NC-SA 4.0 许可协议。转载请注明文章出处。

让学习像火箭一样快速，微信扫码，获取考试解析、体验刷题服务，开启你的学习加速器！

分享考题
share