Hi, casel. 从你描述的场景来看，作业主要问题是在于指标没有变化而重复输出。从sql的角度来看，可以考虑加一个简单的udf将窗口输出的数据进行过滤，只输出有变化的指标。
> 2024年11月8日 15:55，casel.chen <casel_c...@126.com> 写道： > > 假设需要每秒统计过去一天用户登录次数指标的话，一条数据就会落在多达86400个窗口上，每个窗口都会产用state大小，而且每秒输出状态到下游，即使状态没有发生变化也会重复输出，造成下游算子写入压力大，请问有什么好的办法可以规避么？请分别从flink > stream api和sql讲解一下，谢谢！
