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 天的数据?
是的,如果该数据自加载后未被修改,则将在一天后全部删除。
每天过期一天的数据:引导状态后,您可以向自己发送一条延迟消息,设置为在一天后发送。当它到达时,删除最旧的数据并发送另一个延迟消息。
根据this page,我们可以在使用 Flink Statefun v2.1.0 时为状态设置 TTL。
我们也有能力bootstrap状态,根据this page。
第一个问题是,bootstrap 文档根本没有提到状态过期。对具有 TTL 的状态执行 bootstrapping 的正确方法是什么?有人可以给我举个例子吗?
第二个问题是,如果我将某些状态设置为在 1 天写入后过期,然后 bootstrap 该状态使用 6 个月的数据会发生什么情况?
整个 bootstrapped 状态会在 1 天后过期吗?
如果是这样,我该怎么做才能让它在 1 天后过期 1 天的数据?
是的,如果该数据自加载后未被修改,则将在一天后全部删除。
每天过期一天的数据:引导状态后,您可以向自己发送一条延迟消息,设置为在一天后发送。当它到达时,删除最旧的数据并发送另一个延迟消息。