hi,community, 想确认下idlestateretention的配置及生效机制,我有一个作业,设置了TTL为(10小时,10小时+5分钟)。假设我的作业是今天12:00启动,作业逻辑是统计当日10点后每个userId第一次登陆的时间:select userId, first_value(xxx) from source group by userId, date_format(eventtime, 'yyyy-MM-dd')。那么我的作业的状态清理时机是从启动时间开始10小时之后么?还是会按照状态的数据更新的时间+10小时作为清理时间? 我使用flink 1.10.1版本,初步观察到的现象是,启动时间开始大概10小时后,状态开始清理。这个感觉不符合预期?求大佬帮忙确认下。
- flink state ttl状态清理和重新计算的疑问 sunfulin
- Re:Re: flink state ttl状态清理和重新计算的疑问 sunfulin
- Re: Re: flink state ttl状态清理和重新计算的疑问 Benchao Li
