Re: flink sql状态清理问题

Sun, 09 Aug 2020 19:45:51 -0700 

配置了 TableConfig 中的 minIdleStateRetentionTime 和 maxIdleStateRetentionTime 吗？

Benchao Li <libenc...@apache.org> 于2020年8月10日周一 上午10:36写道：

> Hi，
>
> 最好也说一下使用的Flink版本以及对应的SQL，这样可以让其他同学容易复现这个问题。
>
> op <520075...@qq.com> 于2020年8月10日周一 上午10:27写道：
>
> > Hi
> > &nbsp; &nbsp; 在使用flink sql的过程中遇到如下情况，在配置了如下选项后：
> > &nbsp; val config = tableConfig.getConfiguration()
> > &nbsp; &nbsp;&nbsp;config.setString("table.exec.mini-batch.enabled",
> > "true")
> > &nbsp;
> &nbsp;&nbsp;config.setString("table.exec.mini-batch.allow-latency",
> > "5s")
> > &nbsp; &nbsp;&nbsp;config.setString("table.exec.mini-batch.size", "20")
> >
> 无论使用FsStateBackend还是RocksDBStateBackend都无法清理掉空闲状态，运行时可以观察到checkpoint目录下状态大小持续增长；
> > 同一套代码，把这几个配置删掉后，运行时观察checkpoint目录下状态大小不会一直增长，能保持在一个范围内请问这是什么原因？谢谢
>
>
>
> --
>
> Best,
> Benchao Li
>

回复