This is an automated email from the ASF dual-hosted git repository.

huajianlan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new 9d539ccd034 [fix](query cache) AggregateNode compute digest of query 
cache should consider sortByGroupKey (#60431)
9d539ccd034 is described below

commit 9d539ccd034086b6bb2000fbb148939216ade38d
Author: 924060929 <[email protected]>
AuthorDate: Tue Feb 3 11:01:34 2026 +0800

    [fix](query cache) AggregateNode compute digest of query cache should 
consider sortByGroupKey (#60431)
    
    AggregateNode compute digest of query cache should consider sortByGroupKey
---
 fe/fe-core/src/main/java/org/apache/doris/planner/AggregationNode.java | 3 +++
 gensrc/thrift/Normalization.thrift                                     | 1 +
 2 files changed, 4 insertions(+)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/planner/AggregationNode.java 
b/fe/fe-core/src/main/java/org/apache/doris/planner/AggregationNode.java
index 8b57e6fb7cd..b0e0bab2b2b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/AggregationNode.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/AggregationNode.java
@@ -162,6 +162,9 @@ public class AggregationNode extends PlanNode {
 
         normalizedPlan.setNodeType(TPlanNodeType.AGGREGATION_NODE);
         normalizedPlan.setAggregationNode(normalizedAggregateNode);
+        if (sortByGroupKey != null) {
+            normalizedAggregateNode.setSortInfo(sortByGroupKey.toThrift());
+        }
     }
 
     @Override
diff --git a/gensrc/thrift/Normalization.thrift 
b/gensrc/thrift/Normalization.thrift
index fc41489b792..ecc558579be 100644
--- a/gensrc/thrift/Normalization.thrift
+++ b/gensrc/thrift/Normalization.thrift
@@ -44,6 +44,7 @@ struct TNormalizedAggregateNode {
   6: optional bool use_streaming_preaggregation
   7: optional list<Exprs.TExpr> projectToAggIntermediateTuple
   8: optional list<Exprs.TExpr> projectToAggOutputTuple
+  9: optional PlanNodes.TSortInfo sortInfo
 }
 
 struct TNormalizedPlanNode {


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to