Flink Statefun Bootstrap 和 State 过期

Flink Statefun Bootstrap and State expiration

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

我们也有能力bootstrap状态,根据this page

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

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

整个 bootstrapped 状态会在 1 天后过期吗?

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

是的,如果该数据自加载后未被修改,则将在一天后全部删除。

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