当前位置: 首页 > news >正文

【大数据面试题】31 Flink 有哪些重启方法

一步一个脚印,一天一道面试题

Flink 提供了几种不同的重启方法:

  1. 异常自动从 Checkpoint 重启: Checkpoint是Flink的另一种状态快照机制,它比Savepoint更为频繁,提供了细粒度的状态恢复点。通过配置Checkpoint,Flink会周期性地自动保存作业的状态。如果作业失败,Flink可以根据最后一个成功的Checkpoint自动重启并恢复状态,从而达到“恰好一次”或“至少一次”的处理语义。要启用Checkpoint,需要在作业配置中开启Checkpoint并设置Checkpoint的参数,如间隔时间、模式等。

  2. 从Savepoint重启: SavepointCheckpoint 类似,是拿来保存当时状态的一个机制。以便后续可以从这个状态恢复执行。你可以手动触发保存Savepoint。一般是升级,或者更新配置信息之类的时候用。一般手动用的。

  3. 手动重启: 最直接的方法是手动停止作业后,通过Flink的控制台或命令行工具重新提交作业。这种方式不涉及自动化或特定的故障恢复策略,但在调试或测试场景中较为常用。

我是近未来,祝你变得更强!

http://www.lryc.cn/news/356935.html

相关文章:

  • 【IDEA】Redis可视化神器
  • 深入分析 Android Activity (十一)
  • go语言切片、数组去重函数SliceUnique 支持所有值是可比较类型的切片或者数组去重
  • 微信小程序实现计算当前位置到目的地的距离
  • 灵动微单片机洗衣机方案——【软硬件开发支持】
  • EureKa是什么?
  • 【数据结构】直接选择排序详解!
  • vue3中的toRaw API
  • 接口响应断言-json
  • 全面盘点多模态融合算法及应用场景
  • 超分论文走读
  • Android ViewPager2 + FragmentStateAdapter 的使用以及问题
  • FPGA中的乒乓操作
  • gnocchi学习小结
  • 【机器学习】Pandas中to_pickle()函数的介绍与机器学习中的应用
  • lightning的hook顺序
  • 【ARFoundation自学03】AR Point Cloud 点云(参考点标记)功能详解
  • x264 码率控制中实现 VBV 算法源码分析
  • 宝兰德入选“鑫智奖·2024金融数据智能运维创新优秀解决方案”榜单
  • Unity3D雨雪粒子特效(Particle System)
  • 记录使用自定义编辑器做试题识别功能
  • MySQL索引和视图
  • Java单元测试Mock的用法,关于接口测试的用例
  • 《心理学报》文本分析技术最新进展总结盘点
  • json格式文件备份redis数据库 工具
  • JAVA系列:NIO
  • 偏微分方程算法之抛物型方程差分格式编程示例二
  • linux 查看 线程名, 线程数
  • python class __getattr__ 与 __getattribute__ 的区别
  • [ C++ ] 类和对象( 下 )