Flink禁用特定状态的保存点



我在一个flink作业中管理2个不同的状态。但我不需要为他们中的任何一个做保护点。对于其他,我必须采取保存点。

我不想为不必要的保存点设置保存点,因为它会增加保存点的持续时间和大小。

有办法吗?

Flink正在管理的任何状态都将包含在所有保存点和检查点中。这两种类型的状态快照使用相同的底层机制,并包含所有状态。

相关内容

  • 没有找到相关文章

最新更新