[BugFix] Cases with only one-stage local agg don't need to be process…

…ed (#53534) Signed-off-by: stephen <[email protected]> (cherry picked from commit 6fca3c1)
StarRocks · Dec 4, 2024 · 74c8a77 · 74c8a77
1 parent 637159a
commit 74c8a77
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/fe/fe-core/src/main/java/com/starrocks/qe/feedback/skeleton/SkeletonBuilder.java b/fe/fe-core/src/main/java/com/starrocks/qe/feedback/skeleton/SkeletonBuilder.java
@@ -97,7 +97,7 @@ public SkeletonNode visitPhysicalJoin(OptExpression optExpression, SkeletonNode
     public SkeletonNode visitPhysicalHashAggregate(OptExpression optExpression, SkeletonNode parent) {
         int planNodeId = optExpression.getOp().getPlanNodeId();
         PhysicalHashAggregateOperator aggOperator = (PhysicalHashAggregateOperator) optExpression.getOp();
-        if (aggOperator.getType().isAnyGlobal() || !aggOperator.isSplit()) {
+        if (aggOperator.getType().isAnyGlobal()) {
             BlockingAggNode node = new BlockingAggNode(optExpression, nodeExecStatsMap.get(planNodeId), parent);
             visitChildren(node, optExpression.getInputs());
             fillNodeId(optExpression.getOp(), node);