This is an automated email from the ASF dual-hosted git repository. spricoder pushed a commit to branch fix/time_partition in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 711c77f7a59054d73ec42c772f2835cadab2bcbb Author: spricoder <[email protected]> AuthorDate: Wed Mar 12 17:44:09 2025 +0800 add error log --- .../org/apache/iotdb/commons/memory/AtomicLongMemoryBlock.java | 9 +++++++++ .../main/java/org/apache/iotdb/commons/memory/IMemoryBlock.java | 3 --- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/AtomicLongMemoryBlock.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/AtomicLongMemoryBlock.java index 1376d8ddb6d..e4b6fa6be3c 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/AtomicLongMemoryBlock.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/AtomicLongMemoryBlock.java @@ -53,6 +53,9 @@ public class AtomicLongMemoryBlock extends IMemoryBlock { @Override public long forceAllocateWithoutLimitation(long sizeInByte) { + if (name.equals("TimePartitionInfoMemoryBlock")) { + LOGGER.error("TimePartitionInfoMemoryBlock forceAllocateWithoutLimitation {}", sizeInByte); + } return usedMemoryInBytes.addAndGet(sizeInByte); } @@ -101,6 +104,9 @@ public class AtomicLongMemoryBlock extends IMemoryBlock { @Override public long release(long sizeInByte) { + if (name.equals("TimePartitionInfoMemoryBlock")) { + LOGGER.error("TimePartitionInfoMemoryBlock release {}", sizeInByte); + } return usedMemoryInBytes.updateAndGet( memCost -> { if (sizeInByte > memCost) { @@ -115,6 +121,9 @@ public class AtomicLongMemoryBlock extends IMemoryBlock { @Override public void setUsedMemoryInBytes(long usedMemoryInBytes) { + if (name.equals("TimePartitionInfoMemoryBlock")) { + LOGGER.error("TimePartitionInfoMemoryBlock setUsedMemoryInBytes {}", usedMemoryInBytes); + } this.usedMemoryInBytes.set(usedMemoryInBytes); } diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/IMemoryBlock.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/IMemoryBlock.java index 332e82336ac..416516bf2c7 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/IMemoryBlock.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/IMemoryBlock.java @@ -19,8 +19,6 @@ package org.apache.iotdb.commons.memory; -import org.apache.iotdb.commons.utils.TestOnly; - import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -88,7 +86,6 @@ public abstract class IMemoryBlock implements AutoCloseable { * * @param usedMemoryInBytes the memory usage in byte to be set */ - @TestOnly public abstract void setUsedMemoryInBytes(final long usedMemoryInBytes); /** Get the memory usage in byte of this memory block */
