首页 > 解决方案 > Flink Statefun Bootstrap 和状态过期

问题描述

根据此页面,我们可以在使用 Flink Statefun v2.1.0 时为状态设置 TTL。

根据此页面,我们还具有引导状态的能力。

第一个问题是,引导文档根本没有提到状态到期。对具有 TTL 的状态进行引导的正确方法是什么?有人可以给我举个例子吗?

第二个问题是,如果我在写入 1 天后将某个状态设置为过期,然后使用 6 个月的数据引导该状态,会发生什么情况?

整个引导状态是否会在 1 天后过期?

如果是这样,我该怎么做才能让它在 1 天过去后过期 1 天的数据?

标签: javastateapache-flinkttlflink-statefun

解决方案


是的,如果这些数据在加载后没有被修改过,那么它会在一天后被删除。

每天过期一天的数据:在引导状态后,您可以向自己发送一条延迟消息,设置为一天后发送。当它到达时,删除最旧的数据并发送另一条延迟消息。


推荐阅读