Flink CEP如何管理间歇性状态?它存放在哪里?它只是在内存中还是有支持状态的快速持久存储?
文档没有在任何地方提到这一点。
与Flink中的所有有状态操作(例如,窗口,聚合,SQL,计时器等)一样,Flink CEP使用Flink's managed state。如果工作状态被保持,并且持久存在,则取决于使用哪种state backend。 RocksDB状态后端允许大于适合内存的状态,并且检查点持久存储在持久存储中,例如HDFS,S3或NFS。