Flink 的状态管理、Checkpoint 与 Savepoint
Flink 的可靠性建立在状态快照之上,Checkpoint 用于故障恢复,Savepoint 用于升级、迁移和人工控制。
标签
共 3 篇文章
Flink 的可靠性建立在状态快照之上,Checkpoint 用于故障恢复,Savepoint 用于升级、迁移和人工控制。
基于当前仓库实现分析 checkpoint sidecar、active log verified recovery scan 以及残缺/过旧 checkpoint 的保守恢复逻辑。
围绕 checkpoint sidecar、active log verified scan 与 truncate 恢复路径,分析 seastar-log-engine 如何在异常退出后尽快找回一条一致且可继续追加的日志尾部。