Flink Checkpoint/Savepoint对比

Flink提供了Checkpoint和Savepoint两种机制来保证作业的容错性。Savepoint是一种特殊的Checkpoint，用于手动触发并持久化存储结果，主要用于避免状态丢失。Checkpoint是由Flink runtime定时触发并自动清理的，而Savepoint的触发和清理由用户掌控。由于Checkpoint的频率较高，Flink对其格式进行了优化，但耦合性较强。Savepoint是全量的，不支持增量。Savepoint更关注可移植性和版本兼容性。