开启 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/ >