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);
}