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 <[email protected]> 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); }
