是的。 sunfulin <sunfulin0...@163.com> 于2020年8月14日周五 下午3:01写道：
> hi, benchao, > 感谢回复，那我是不是可以理解为：去掉minibatch，就可以状态过期清理了哈？ > > > > > > > > > > > > > > > > > > 在 2020-08-14 14:09:33，"Benchao Li" <libenc...@apache.org> 写道： > >Hi, > >现在group agg + mini batch 还没有支持状态过期清理，已经有工作[1] 在解决这个问题了。 > > > >[1] https://issues.apache.org/jira/browse/FLINK-17096 > > > >sunfulin <sunfulin0...@163.com> 于2020年8月14日周五 下午2:06写道： > > > >> hi，我的一个flink sql作业，在启用了idlestateretentiontime设置后，观察到web ui上的state > >> size还是一直在增大，超过maximum retention time之后state大小也没有减小的情况，请问这个可能是啥原因哈？ > >> > >> > >> 使用的flink 版本：flink 1.10.1，启用的state > >> ttl配置：tableEnv.getConfig.setIdleStateRetentionTime(Time.minutes(5), > >> Time.minutes(10)); > >> 我的作业逻辑是：统计每个userId每天第一次出现的记录，类似：select userId, first_value(xxx) from > >> source group by userId, date_format(eventtime, 'yyyy-MM-dd'); > > > > > > > >-- > > > >Best, > >Benchao Li > -- Best, Benchao Li
