apache-flink - Flink：关于 flink 检查点和保存点的查询

Question

以下是我对 Flink 的疑问。

1. 我们可以将检查点和保存点存储到 RockDB 等外部数据结构中吗？或者它只是我们可以存储在 RockDB 等中的状态吗？
2. 状态后端会影响检查点吗？如果是，以什么方式？
3. 什么是状态处理器 API？它是否与我们存储的保存点和检查点直接相关？StateProcessor API 提供了哪些普通保存点无法提供的额外好处？

对于 3 个问题，请尽可能描述性地回答。我对学习 StateProcessor API 很感兴趣，但我想深入了解它的应用，以及它在哪些场景中不可或缺。

Answer 1

1. 检查点和保存点只能写入满足 Flink文件系统抽象要求的存储。您想使用具有持久性和冗余性的东西，例如 S3 或 HDFS。RocksDB 不支持作为检查点或保存点的数据存储。

2. 状态后端涉及检查点，检查点以特定于状态后端的格式编写。基于堆和基于 RocksDB 的状态后端在检查点方面最显着的区别是只有 RocksDB 状态后端支持增量检查点。

3. 状态处理器 API 允许您编写可以读取和写入保存点（和外部化检查点）的应用程序。这对于检查应用程序的状态以进行分析或调试、执行状态迁移和引导新应用程序的状态很有用，举几个例子。