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: hdxg1101300...@163.com <hdxg1101300...@163.com>
Sent: Thursday, July 2, 2020 11:17
To: user-zh <user-zh@flink.apache.org>
Subject: flink的state过期设置

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



hdxg1101300...@163.com

Reply via email to