Skip to content

Commit

Permalink
[BugFix] Cases with only one-stage local agg don't need to be process…
Browse files Browse the repository at this point in the history
…ed (backport #53534) (#53563)

Co-authored-by: stephen <[email protected]>
  • Loading branch information
mergify[bot] and stephen-shelby authored Dec 5, 2024
1 parent 99b4e60 commit 5c0da8b
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down

0 comments on commit 5c0da8b

Please sign in to comment.