flink cep如何管理间歇状态?它们存放在哪里?它只是在内存中,还是有一个支持状态的快速持久存储?文件中没有提到这一点。
daupos2t1#
与flink中的所有有状态操作(如windows、聚合、sql、计时器等)一样,flink cep使用flink的托管状态。工作状态保存在何处以及持久保存在何处,取决于使用哪个状态后端。rocksdb state后端允许大于内存大小的状态,并且检查点持久存在于持久存储中,比如hdfs、s3或nfs。
1条答案
按热度按时间daupos2t1#
与flink中的所有有状态操作(如windows、聚合、sql、计时器等)一样,flink cep使用flink的托管状态。工作状态保存在何处以及持久保存在何处,取决于使用哪个状态后端。rocksdb state后端允许大于内存大小的状态,并且检查点持久存在于持久存储中,比如hdfs、s3或nfs。