flinkstatefun引导和状态过期

67up9zun  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(384)

根据这个页面,我们有能力设置ttl的状态时,使用FlinkStateFunv2.1.0。
我们也有能力引导状态,根据这一页。
第一个问题是,引导程序文档根本没有提到状态过期。在具有ttl的状态上进行引导的正确方法是什么?有人能给我举个例子吗?
第二个问题是,如果我将某个状态设置为在写入1天后过期,然后使用6个月的数据引导该状态,会发生什么?
整个引导状态会在1天后过期吗?
如果是这样,我该怎么做才能让它在1天后过期1天的数据?

cunj1qz1

cunj1qz11#

是的,如果该数据在加载后未被修改,则一天后将全部删除。
每天使一天的数据过期:在引导状态后,您可以向自己发送一条延迟消息,设置为一天后发送。当它到达时,删除最旧的数据并发送另一个延迟消息。

相关问题