apache-flink - Flink CEP 状态存储

标签 apache-flink flink-streaming flink-cep

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/

相关文章:

apache-flink - 为什么我的 Flink 窗口使用这么多状态?

apache-flink - Flink 中插槽的资源过度分配

apache-flink - Apache Flink 中的周期性水印和标点水印有什么区别?

kubernetes - Kubernetes 上的 Apache flink - 如果作业管理器崩溃,则恢复作业

java - 在没有所有 Flink 环境的情况下使用 flink-cep 模式匹配

java - 在 Stream Start 之前访问 Flink Classloader

apache-flink - StreamTask.getCheckpointLock 弃用和自定义 Flink 源

scala - 使用 scala 在 Flink 中进行实时流预测

apache-flink - 如何处理 Apache Flink 中的 transient /应用程序故障?