赞
踩
Checkpoint的原理
Flink checkpoint是一种容错恢复机制,保证 Flink 任务运行突然失败时,能够从最近 Checkpoint 进行状态恢复启动,进行错误容忍,是在Chandy–Lamport算法的基础上实现的一种分布式快照算法,其内部使用分布式数据流轻量级异步快照。
Checkpoint流程
Checkpoint的内容
Checkpoint支持语义
Exactly Once实现方式
Exactly Once
kafka只有一个partition,Exactly Once 和 At Least Once有没有区别
Checkpoint状态保留策略
Checkpoint潜在问题及解决方案
Checkpoint失败原因分析
Checkpoint慢的原因分析
参考
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。