开启 minibatch 可以基本解决中间结果的问题:
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/tuning/streaming_aggregation_optimization.html#minibatch-aggregation

Best,
Jark

On Fri, 18 Sep 2020 at 11:57, xushanshan <1337220...@qq.com> wrote:

> 问题内容已修改补充完成
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>

回复