Flink1.10 flinksql 多表join状态ttl不成功的问题

Tue, 14 Jul 2020 00:36:36 -0700 

<http://apache-flink.147419.n8.nabble.com/file/t447/ttl.png> 
我用flink sql 设置了 空闲状态的清理时间，但是 状态还是一直增加，里面有 多次 group by  和多次 流表的关联 。
代码如下：
   tEnv.getConfig()
         .setIdleStateRetentionTime(Time.hours(minIdleStateRetentionTime), 
                                                
Time.hours(maxIdleStateRetentionTime));

程序运行一周之后状态现在2.2G. 最近几天越来越大，表现在ttl没有成功，请教一下各位大佬



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

回复