【问题标题】:Flink Statefun Bootstrap and State expirationFlink Statefun Bootstrap 和状态过期
【发布时间】:2020-07-24 17:16:05
【问题描述】:

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

根据this page,我们还可以引导状态。

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

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

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

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

【问题讨论】:

    标签: java state apache-flink ttl flink-statefun


    【解决方案1】:

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

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

    【讨论】:

      猜你喜欢
      • 2020-11-03
      • 2020-07-24
      • 1970-01-01
      • 2022-12-15
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多