[iotdb] branch master updated: Fix the issue when doing distribution plan for aggregation

[jackietien]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new bcd0305f70 Fix the issue when doing distribution plan for aggregation
bcd0305f70 is described below

commit bcd0305f709205d89e436df1b4ce835e6a87ea85
Author: Zhang.Jinrui <xingtan...@gmail.com>
AuthorDate: Fri Nov 25 20:59:12 2022 +0800

    Fix the issue when doing distribution plan for aggregation
---
 .../apache/iotdb/db/mpp/plan/planner/distribution/SourceRewriter.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SourceRewriter.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SourceRewriter.java
index 2274c6ce1e..b8f3f8fcb9 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SourceRewriter.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SourceRewriter.java
@@ -408,7 +408,7 @@ public class SourceRewriter extends 
SimplePlanNodeRewriter<DistributionPlanConte
             node.getGroupByTimeParameter(),
             node.getScanOrder());
     for (TRegionReplicaSet dataRegion : dataDistribution) {
-      SeriesAggregationScanNode split = (SeriesAggregationScanNode) 
node.clone();
+      SeriesAggregationSourceNode split = (SeriesAggregationSourceNode) 
node.clone();
       split.setAggregationDescriptorList(leafAggDescriptorList);
       split.setPlanNodeId(context.queryContext.getQueryId().genPlanNodeId());
       split.setRegionReplicaSet(dataRegion);