我有一个值状态存储一些计算数据,这些数据将被频繁访问并且计算起来非常昂贵,所以我使用一个值状态在键控过程函数中缓存该信息。
从 Flink 文档中,我认为设置 TTL 并没有明确清理,但它是懒惰地完成的。这提出了一个问题,因为我有很多状态数据并导致作业内存不足。
有没有办法明确释放状态?如果状态超过 10 分钟没有被读取,就把它从 ram 中释放出来。