Flink Checkpoint/Savepoint对比
原文中文,约800字,阅读约需2分钟。发表于: 。Flink 为作业的容错提供 Checkpoint 和 Savepoint 两种机制。保存点机制(Savepoints)是检查点机制一种特殊的实现,它允许你通过手工方式来触发Checkpoint,并将结果持久化存储到指定路径中,主要用于避免Flink集群在重启或升级时导致状态丢失。
Flink提供了Checkpoint和Savepoint两种机制来保证作业的容错性。Savepoint是一种特殊的Checkpoint,用于手动触发并持久化存储结果,主要用于避免状态丢失。Checkpoint是由Flink runtime定时触发并自动清理的,而Savepoint的触发和清理由用户掌控。由于Checkpoint的频率较高,Flink对其格式进行了优化,但耦合性较强。Savepoint是全量的,不支持增量。Savepoint更关注可移植性和版本兼容性。