假设需要每秒统计过去一天用户登录次数指标的话,一条数据就会落在多达86400个窗口上,每个窗口都会产用state大小,而且每秒输出状态到下游,即使状态没有发生变化也会重复输出,造成下游算子写入压力大,请问有什么好的办法可以规避么?请分别从flink
 stream api和sql讲解一下,谢谢!

回复