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
The following commit(s) were added to refs/heads/beyyes/align_by_time_topk by
this push:
new 359f31c999c add unit for no no enough memory
359f31c999c is described below
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;