admin管理员组

文章数量:1026989

Flink 利用 Checkpoint 实现故障恢复

传送门：Flink 系统性学习笔记

Flink 1.13.5 版本

在本节中，我们将介绍 Flink 如何利用检查点 Checkpoint 实现故障恢复。

1. 配置

如果我们的任务已经执行很长时间，突然遇到故障停止，那么中间过程处理结果就会全部丢失，重启后如果需要重新从上线开始的位置消费，那么会花费我们很长的时间。这种结局显示我们不能接受，我们希望的是作业在故障失败重启后能保留之前的状态并能从失败的位置继续消费。这就需要 Flink 利用检查点 Checkpoint 实现故障恢复并保证精确一次 Exactly-Once 语义的一致性状态。可以通过如下配置设置 Checkpoint：

final StreamExecutionEnvironment env = StreamExecutionEnvironment.

Flink 利用 Checkpoint 实现故障恢复

传送门：Flink 系统性学习笔记

Flink 1.13.5 版本

在本节中，我们将介绍 Flink 如何利用检查点 Checkpoint 实现故障恢复。

1. 配置

如果我们的任务已经执行很长时间，突然遇到故障停止，那么中间过程处理结果就会全部丢失，重启后如果需要重新从上线开始的位置消费，那么会花费我们很长的时间。这种结局显示我们不能接受，我们希望的是作业在故障失败重启后能保留之前的状态并能从失败的位置继续消费。这就需要 Flink 利用检查点 Checkpoint 实现故障恢复并保证精确一次 Exactly-Once 语义的一致性状态。可以通过如下配置设置 Checkpoint：

final StreamExecutionEnvironment env = StreamExecutionEnvironment.

本文标签： Flink 利用 Checkpoint 实现故障恢复

版权声明：本文标题：Flink 利用 Checkpoint 实现故障恢复 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://it.en369.cn/IT/1694670539a254866.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。