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

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

最佳答案

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

关于apache-flink - Flink CEP 状态存储,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/47843581/

10-13 04:35