[iotdb] branch xingtanzjr/fix_agg_plan created (now 7f92b6a3b8)

[xi...@apache.org]

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

xingtanzjr pushed a change to branch xingtanzjr/fix_agg_plan
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 7f92b6a3b8 fix the issue when doing distribution plan for agg

This branch includes the following new commits:

     new 7f92b6a3b8 fix the issue when doing distribution plan for agg

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[iotdb] 01/01: fix the issue when doing distribution plan for agg

[xi...@apache.org]

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

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

commit 7f92b6a3b8722ab95850a21766ee026df21ac9e7
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Fri Nov 25 20:52:19 2022 +0800

    fix the issue when doing distribution plan for agg
---
 .../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);