Flink 在超时后显式释放状态

问题描述 投票:0回答:0

我有一个值状态存储一些计算数据,这些数据将被频繁访问并且计算起来非常昂贵,所以我使用一个值状态在键控过程函数中缓存该信息。

从 Flink 文档中,我认为设置 TTL 并没有明确清理,但它是懒惰地完成的。这提出了一个问题,因为我有很多状态数据并导致作业内存不足。

有没有办法明确释放状态?如果状态超过 10 分钟没有被读取,就把它从 ram 中释放出来。

state apache-flink flink-streaming
© www.soinside.com 2019 - 2024. All rights reserved.