你这个直接按照天分窗就可以呀。 三色堇 <[email protected]> 于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))这两种方式并不能满足我的需求，请教一下有其他方法可以实现这种日报需求吗？
