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

[LiangbinZhang]

<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/

[Jark]

Hi,

请问用的是什么版本，blink planner 还是 old planner？
有没有简化一点的 query 也能复现这个 ttl 问题的？ 比如一层 groupby？

Best,
Jark

On Tue, 14 Jul 2020 at 15:36, Robin Zhang <[hidden email]>
wrote:

> <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/
>