You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2025/03/05 09:58:32 UTC
(iotdb) 01/01: add more logs for operator
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch beyyes/make_log_tidy
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3eb8929b7ac811c6f92e3f8d660b94789d8ffcd3
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Wed Mar 5 17:57:57 2025 +0800
add more logs for operator
---
.../org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java | 4 +++-
.../iotdb/db/queryengine/execution/operator/AbstractOperator.java | 5 ++++-
2 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java
index a9ab6ed5d81..638fb694c04 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java
@@ -247,7 +247,9 @@ public class MemoryPool {
maxBytesCanReserve,
planNodeId);
throw new IllegalArgumentException(
- "Query is aborted since it requests more memory than can be allocated.");
+ String.format(
+ "Query is aborted since it requests more memory than can be allocated, bytesToReserve: %sB, maxBytesCanReserve: %sB",
+ bytesToReserve, maxBytesCanReserve));
}
ListenableFuture<Void> result;
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/AbstractOperator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/AbstractOperator.java
index 5c6d731f9a0..41d1f163f81 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/AbstractOperator.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/AbstractOperator.java
@@ -49,7 +49,10 @@ public abstract class AbstractOperator implements Operator {
if (oneTupleSize > maxReturnSize) {
// make sure at least one-tuple-at-a-time
this.maxTupleSizeOfTsBlock = 1;
- LOGGER.warn("Only one tuple can be sent each time caused by limited memory");
+ LOGGER.warn(
+ "Only one tuple can be sent each time caused by limited memory, oneTupleSize: {}B, maxReturnSize: {}B",
+ oneTupleSize,
+ maxReturnSize);
} else {
this.maxTupleSizeOfTsBlock = (int) (maxReturnSize / oneTupleSize);
}