Hi, this node exists when you are using a Windowing TVF[1] and using mini-batch, and then planner will optimize the plan tree with local-global aggregation[2]. You can find the benefits of local global optimization in doc above.
If you don't need this optimization, set 'table.optimizer.agg-phase-strategy' to ONE_PHASE to disable it. BTW, could you using jstack to show what is the thread doing? [1] https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/sql/queries/window-tvf/ [2] https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/table/tuning/#local-global-aggregation -- Best！ Xuyang At 2023-10-27 16:36:15, "Kenan Kılıçtepe" <kkilict...@gmail.com> wrote: Hi, Can someone tell what GlobalWindowAggregate is? it is always %100 busy in my job graph. GlobalWindowAggregate(groupBy=[deviceId, fwVersion, modelName, manufacturer, phoneNumber], window=[TUMBLE(slice_end=[$slice_end], size=[3 h])], select=[deviceId, fwVersion, modelName, manufacturer, phoneNumber, COUNT(distinct$0 count$0) AS CNT, start('w$) AS window_start, end('w$) AS window_end]) Thanks
