This is an automated email from the ASF dual-hosted git repository. xiangweiwei pushed a commit to branch memoryDistribution1.0 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ad0de56f153de771a874609b3322178f0448074a Author: Alima777 <[email protected]> AuthorDate: Thu Dec 22 16:40:10 2022 +0800 change long to int --- .../org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java | 2 +- .../apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java index 5b6d2abc86..36d53f6279 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java @@ -126,7 +126,7 @@ public class LocalExecutionPlanner { private void setMemoryLimitForHandle(TFragmentInstanceId fragmentInstanceId, PlanNode plan) { MemoryDistributionCalculator visitor = new MemoryDistributionCalculator(); plan.accept(visitor, null); - long totalSplit = visitor.calculateTotalSplit(); + int totalSplit = visitor.calculateTotalSplit(); if (totalSplit == 0) { return; } diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java index 8d420ee53c..d18c7c36d6 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java @@ -79,7 +79,7 @@ public class MemoryDistributionCalculator /** This map is used to calculate the total split of memory */ private int exchangeNum; - public long calculateTotalSplit() { + public int calculateTotalSplit() { return exchangeNum; }
