flink检查点状态大小

[Dream-底限]

streamTableEnv.getConfig().setIdleStateRetentionTime(Time.minutes(15), Time.minutes(20));
我在程序中设置状态保留时间，然后用全局group进行计算，但是过期状态没有清理导致状态也来越大，最终内存溢出，请问这是什么原因导致的
运行SQL
select count(distinct id) as user_count,adjust_time from (select data.f13 as country_id,data.f1 as id,concat(DATE_FORMAT(FROM_UNIXTIME(data.f12/1000),'yyyy-MM-dd HH:mm'),':00') as adjust_time from userActionLog3) access_user_count where country_id='1' group by adjust_time


发送自 Windows 10 版邮件应用