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 <[email protected]> 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);
