Apache Flink 进阶教程(三):Checkpoint 的应用实践 Apache Flink 进阶教程(三):Checkpoint 的应用实践 Flink 里面的 Checkpoint,共分为四个部分。首先讲一下 Checkpoint 与 state 的关系,然后介绍什么是 state,第三部分介绍如何在 Flink 中使用state,第四部分则介绍 Checkpoint 的执行机制。
Flink Checkpoint 问题排查实用指南 Flink Checkpoint 问题排查实用指南 在 Flink 中,状态可靠性保证由 Checkpoint 支持,当作业出现 failover 的情况下,Flink 会从最近成功的 Checkpoint 恢复。在实际情况中,我们可能会遇到 Checkpoint 失败,或者 Checkpoint 慢的情况,本文会统一聊一聊 Flink 中 Checkpoint 异常的情况(包括失败和慢),以及可能的原因和排查思路。
Apache Flink 管理大型状态之增量 Checkpoint 详解 Apache Flink 管理大型状态之增量 Checkpoint 详解 Apache Flink 是一个有状态的流计算框架,状态是作业算子中已经处理过的内存状态,供后续处理时使用。而状态在流计算很多复杂场景中非常重要。