Flinkcep国营商店

unguejic  于 2021-06-25  发布在  Flink
关注(0)|答案(1)|浏览(362)

flink cep如何管理间歇状态?它们存放在哪里?它只是在内存中,还是有一个支持状态的快速持久存储?
文件中没有提到这一点。

daupos2t

daupos2t1#

与flink中的所有有状态操作(如windows、聚合、sql、计时器等)一样,flink cep使用flink的托管状态。工作状态保存在何处以及持久保存在何处,取决于使用哪个状态后端。rocksdb state后端允许大于内存大小的状态,并且检查点持久存在于持久存储中,比如hdfs、s3或nfs。

相关问题