Apache Flink - 检查点和保存点之间的区别?

Raj*_*aja 9 apache-flink

有人可以帮我理解Apache Flink的Checkpoints和Savepoints之间的区别.

虽然我阅读文档,但无法理解差异!:■

Daw*_*icz 12

Apache Flink的检查点和保存点类似,它们都是保留Flink应用程序内部状态的机制.

检查点自动进行,并在发生故障时用于自动重启作业.

另一方面,保存点是手动获取的,总是存储在外部,并且用于在以下情况下启动具有先前内部状态的"新"作业.

  • 错误修复
  • flink版本升级
  • A/B测试等

它们实际上是相同的机制/代码路径,具有一些微妙的细微差别.