hi,我的一个flink sql作业,在启用了idlestateretentiontime设置后,观察到web ui上的state 
size还是一直在增大,超过maximum retention time之后state大小也没有减小的情况,请问这个可能是啥原因哈?


使用的flink 版本:flink 1.10.1,启用的state 
ttl配置:tableEnv.getConfig.setIdleStateRetentionTime(Time.minutes(5), 
Time.minutes(10));
我的作业逻辑是:统计每个userId每天第一次出现的记录,类似:select userId, first_value(xxx) from source 
group by userId, date_format(eventtime, 'yyyy-MM-dd');

回复