增加一个定时器，可以指定时间做清理动作。可以参考flink中window trigger的相关代码和实现。
--
Sent from: http://apache-flink.147419.n8.nabble.com/
"user-zh"
> <
> hinobl...@gmail.com>;
> 发送时间: 2020年12月18日(星期五) 晚上9:50
> 收件人: "user-zh"
> 主题: Re: 请教一下flink1.12可以指定时间清除state吗？
>
>
>
> 你这个直接按照天分窗就可以呀。
>
> 三色堇 <25977...@qq.com> 于2020年12月18日周五 下午3:20写道：
>
&g
你这个直接按照天分窗就可以呀。
三色堇 <25977...@qq.com> 于2020年12月18日周五 下午3:20写道：
> Hi，社区的各位大家好： 请教一下，我目前生产上使用的flink1.12，根据公司需求，统计每天的日报，每天出一组结果。已经做了group
> by current_date,userId 过程中我发现隔天的flink state未清理，还是在前一天的结果上累加，自己也测试了
> 1、Stream的TTL
> 2、tabEnv.getConfig().setIdleStateRetention(Duration.ofDays(1))这两种方式并不能满足我的
