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


The following commit(s) were added to refs/heads/fix/time_partition by this 
push:
     new 3b8b000e406 Remove Bytes
3b8b000e406 is described below

commit 3b8b000e4062c84f71d535b9949f04680cd4c2e5
Author: spricoder <[email protected]>
AuthorDate: Wed Mar 12 18:07:22 2025 +0800

    Remove Bytes
---
 .../db/storageengine/rescon/memory/TimePartitionManager.java     | 2 +-
 .../org/apache/iotdb/commons/memory/AtomicLongMemoryBlock.java   | 9 ---------
 2 files changed, 1 insertion(+), 10 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/memory/TimePartitionManager.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/memory/TimePartitionManager.java
index 30771e3db78..83fc8c7eb0c 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/memory/TimePartitionManager.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/memory/TimePartitionManager.java
@@ -125,7 +125,7 @@ public class TimePartitionManager {
         if (timePartitionInfo == null) {
           return;
         }
-        timePartitionInfoMemoryBlock.release(timePartitionInfo.memSize + 
Long.BYTES);
+        timePartitionInfoMemoryBlock.release(timePartitionInfo.memSize);
         DataRegion dataRegion =
             
StorageEngine.getInstance().getDataRegion(timePartitionInfo.dataRegionId);
         if (dataRegion != null) {
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 e4b6fa6be3c..1376d8ddb6d 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,9 +53,6 @@ public class AtomicLongMemoryBlock extends IMemoryBlock {
 
   @Override
   public long forceAllocateWithoutLimitation(long sizeInByte) {
-    if (name.equals("TimePartitionInfoMemoryBlock")) {
-      LOGGER.error("TimePartitionInfoMemoryBlock 
forceAllocateWithoutLimitation {}", sizeInByte);
-    }
     return usedMemoryInBytes.addAndGet(sizeInByte);
   }
 
@@ -104,9 +101,6 @@ 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) {
@@ -121,9 +115,6 @@ public class AtomicLongMemoryBlock extends IMemoryBlock {
 
   @Override
   public void setUsedMemoryInBytes(long usedMemoryInBytes) {
-    if (name.equals("TimePartitionInfoMemoryBlock")) {
-      LOGGER.error("TimePartitionInfoMemoryBlock setUsedMemoryInBytes {}", 
usedMemoryInBytes);
-    }
     this.usedMemoryInBytes.set(usedMemoryInBytes);
   }
 

Reply via email to