你好，感谢回复。我使用reduce解决了问题。 祝好运。 ________________________________ 发件人: weijie guo <guoweijieres...@gmail.com> 发送时间: 2023年7月26日 10:50 收件人: user-zh@flink.apache.org <user-zh@flink.apache.org> 主题: Re: 关于DataStream API计算批数据的聚合值
你好： Batch 模式下的 reduce 操作默认应该就是只输出最后一条数据(per-key)的。Agg 的话可能有点麻烦，可以使用 GlobalWindow + 自定义 Trigger 来 Workaround. Best regards, Weijie Liu Join <lzy139...@outlook.com> 于2023年7月26日周三 09:10写道： > 例如：我使用DataStream api计算批数据也就是有界流的平均值，如何实现只输出最后一条平均值的数据，不输出中间值 >
