flink的state过期设置

[1101300123]

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



[hidden email]

[Yun Tang]

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: [hidden email] <[hidden email]>
Sent: Thursday, July 2, 2020 11:17
To: user-zh <[hidden email]>
Subject: flink的state过期设置

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



[hidden email]