3

Flink CEP 如何管理间歇性状态?它在哪里存储它们?它只是在内存中还是有支持状态的快速持久存储?

该文档在任何地方都没有提到这一点。

4

1 回答 1

2

与 Flink 中的所有有状态操作(例如,窗口、聚合、SQL、计时器等)一样,Flink CEP 使用Flink 的托管状态。工作状态在哪里保存,在哪里持久保存,取决于使用哪个状态后端。RocksDB 状态后端允许大于内存的状态,并且检查点持久存储在 HDFS、S3 或 NFS 等持久​​存储中。

于 2017-12-16T09:28:27.223 回答