Re: flink sql状态清理问题

2020-08-09 文章 godfrey he
配置了 TableConfig 中的 minIdleStateRetentionTime 和 maxIdleStateRetentionTime 吗? Benchao Li 于2020年8月10日周一 上午10:36写道: > Hi, > > 最好也说一下使用的Flink版本以及对应的SQL,这样可以让其他同学容易复现这个问题。 > > op <520075...@qq.com> 于2020年8月10日周一 上午10:27写道: > > > Hi > > 在使用flink sql的过程中遇到如下情况,在配置了如下选项后: > > val config =

Re: flink sql状态清理问题

2020-08-09 文章 Benchao Li
Hi, 最好也说一下使用的Flink版本以及对应的SQL,这样可以让其他同学容易复现这个问题。 op <520075...@qq.com> 于2020年8月10日周一 上午10:27写道: > Hi > 在使用flink sql的过程中遇到如下情况,在配置了如下选项后: > val config = tableConfig.getConfiguration() > config.setString("table.exec.mini-batch.enabled", > "true") >

Re: Flink sql 状态清理问题

2020-06-10 文章 Benchao Li
Hi, Join算子的state是支持清理的。 可以提供下以下信息: - Flink 版本 - planner (blink planner / old planner) op <520075...@qq.com> 于2020年6月10日周三 下午4:08写道: > hi, > 写了个测试程序: > > .. > > val tConfig = bstEnv.getConfig > > confg.withIdleStateRetentionTime(Time.minutes(10),Time.minutes(25)) > > .. > > val