配置了 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 =
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")
>
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