flink 1.9.1状态持续增大

Hello，我这面用FlinkKafkaConsumer011订阅topic list，在设置过期时间后过期状态没有清理，请问有什么解决办法吗， 并且使用双流union过期状态也是不清理，但是单流的和单topic的情况是可以清理的，请问这是bug吗 发送自 Windows 10 版邮件应用

flink检查点状态大小

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_UNIXTI