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/
