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 Storm☀️ <st...@163.com> on 2020/12/17 08:01:23 UTC

Re: 使用sql时候，设置了idle过期时间，但是状态还是一直变大

flink 1.10.1 同样遇到这个问题 设置了ttl但是没有生效，请问题主解决该问题了吗？
*sql*:
select
* 
from 
xx
group by 
TUMBLE(monitor_processtime, INTERVAL '60' SECOND),topic_identity

*60s的窗口，设置的过期时间是2分钟，但是checkpoint中状态还是在变大*

*tEnv.getConfig().setIdleStateRetentionTime(Time.minutes(2),
Time.minutes(5)); *
               



--
Sent from: http://apache-flink.147419.n8.nabble.com/