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

Question

下面是我对Flink的疑问。

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

对于3个问题，请尽可能描述性地回答。我对学习状态处理器API很感兴趣，但我想深入了解它的应用程序以及它在哪些场景中是必不可少的。

Answer 1

>

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

状态后端参与检查点，检查点以特定于状态后端的格式编写。基于堆的状态后端和基于rocksdb的状态后端在检查点方面的最大区别在于，只有rocksdb状态后端支持增量检查点。

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