Re: 请教Cumulate Windows问题

Hi！ 你可能想要的是 tumble window，具体见 https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sql/queries/window-agg/ xiaocuyu 于2021年9月13日周一 上午11:56写道： > 各位社区大佬： > 您好！ > 在使用Flink SQL中，我有一个需求是：对当天所有的数据进行聚合，然后固定时间输出聚合结果，目前感觉Cumulate >

请教Cumulate Windows问题

各位社区大佬： 您好！ 在使用Flink SQL中，我有一个需求是：对当天所有的数据进行聚合，然后固定时间输出聚合结果，目前感觉Cumulate Windows这种窗口比较符合要求，但是这种窗口有个问题，每次输出会将窗口中所有的值都重新计算，然后输出，这样会导致下游的输出随着时间推移，每次的输出会越来越多。 是否有方法，在输出的时候，仅输出上一个输出，到本次输出，值有变化的那些数据呢？ 目前我这边尝试，使用Cumulate Windows后，先Sink 到Kafka的一个Topic，然后再使用Upsert Kafka