Flink CEP状态存储

Question

Flink CEP如何管理间歇性状态？它将它们存储在哪里？它只是在内存中，还是有一个快速的持久存储来支持这些状态？

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

Answer 1

像Flink中的所有有状态操作(例如，窗口、聚合、SQL、计时器等)一样，Flink CEP使用Flink's managed state。在哪里保持工作状态，在哪里持久地保持工作状态，这取决于正在使用的state backend。RocksDB状态后端允许大于内存容量的状态，并且检查点持久存储在持久存储中。