This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch beyyes/align_by_time_topk in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 359f31c999c36cfd0625f62a7eb978b3d1ac5a48 Author: Beyyes <[email protected]> AuthorDate: Thu Jan 25 10:59:18 2024 +0800 add unit for no no enough memory --- .../iotdb/db/queryengine/execution/schedule/DriverScheduler.java | 2 +- .../iotdb/db/queryengine/plan/planner/LocalExecutionPlanner.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/DriverScheduler.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/DriverScheduler.java index 572aeeb9a78..e8ddb8161d5 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/DriverScheduler.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/DriverScheduler.java @@ -257,7 +257,7 @@ public class DriverScheduler implements IDriverScheduler, IService { .getThrottleQuotaLimit() .checkMemory(sessionInfo.getUserName(), estimatedMemory.get())) { throw new MemoryNotEnoughException( - "There is not enough memory to execute current fragment instance"); + "There is no enough memory to execute current fragment instance"); } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/LocalExecutionPlanner.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/LocalExecutionPlanner.java index 48932a9b60c..7e9c8f773c0 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/LocalExecutionPlanner.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/LocalExecutionPlanner.java @@ -132,8 +132,8 @@ public class LocalExecutionPlanner { throw new MemoryNotEnoughException( String.format( "There is not enough memory to execute current fragment instance, " - + "current remaining free memory is %d, " - + "estimated memory usage for current fragment instance is %d", + + "current remaining free memory is %dB, " + + "estimated memory usage for current fragment instance is %dB", freeMemoryForOperators, estimatedMemorySize)); } else { freeMemoryForOperators -= estimatedMemorySize;
