[iotdb] branch memoryDistribution updated: change long to int

[xiangweiwei]

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

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


The following commit(s) were added to refs/heads/memoryDistribution by this 
push:
     new f6fb245a0d change long to int
f6fb245a0d is described below

commit f6fb245a0de5807aed9f51d7466d4401c242fb49
Author: Alima777 <wxw19981...@gmail.com>
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 5120e73647..508ef15794 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
@@ -82,7 +82,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;
   }