You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "hdxg1101300123@163.com" <hd...@163.com> on 2020/07/02 03:17:04 UTC

flink的state过期设置

您好：
    想咨询一下关于state的ttl问题;
    想问一下 state设置的ttl,如果从checkpoints重启 ttl会不会失效；ttl针对的是process time，
    比如我设置的7天过期,重新从checkpoints启动是第一次启动的时间算还是恢复时的新processtime算；他是state的一部分 还是怎么算；
   或者要注册定时器来实现



hdxg1101300123@163.com

Re: flink的state过期设置

Posted by Yun Tang <my...@live.com>.

Hi

TTL的时间戳实际是会存储在 state 里面 [1]，与每个entry在一起，也就是说从Checkpoint恢复的话，数据里面的时间戳是当时插入时候的时间戳。

[1] https://github.com/apache/flink/blob/ba92b3b8b02e099c8aab4b2b23a37dca4558cabd/flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlValueState.java#L50

祝好
唐云

________________________________
From: hdxg1101300123@163.com <hd...@163.com>
Sent: Thursday, July 2, 2020 11:17
To: user-zh <us...@flink.apache.org>
Subject: flink的state过期设置

您好：
    想咨询一下关于state的ttl问题;
    想问一下 state设置的ttl,如果从checkpoints重启 ttl会不会失效；ttl针对的是process time，
    比如我设置的7天过期,重新从checkpoints启动是第一次启动的时间算还是恢复时的新processtime算；他是state的一部分 还是怎么算；
   或者要注册定时器来实现



hdxg1101300123@163.com