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

回复