Load: Switched the logger level to debug when cache memory temporarily exceeds the max size (apache#16289)

Caideyipi · web-flow · commit 24bf08ae1a96 · 2025-08-27T18:04:38.000+08:00
* fix

* fix

* comment
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileDataCacheMemoryBlock.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileDataCacheMemoryBlock.java
@@ -59,8 +59,9 @@ public boolean hasEnoughMemory(long memoryTobeAddedInBytes) {
 
   @Override
   public synchronized void addMemoryUsage(long memoryInBytes) {
+    // May temporarily exceed the max size
     if (memoryUsageInBytes.addAndGet(memoryInBytes) > limitedMemorySizeInBytes.get()) {
-      LOGGER.warn("{} has exceed total memory size", this);
+      LOGGER.debug("{} has exceed total memory size", this);
     }
   }
 
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryBlock.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileMemoryBlock.java
@@ -50,8 +50,9 @@ public synchronized boolean hasEnoughMemory(long memoryTobeAddedInBytes) {
 
   @Override
   public synchronized void addMemoryUsage(long memoryInBytes) {
+    // May temporarily exceed the max size
     if (memoryUsageInBytes.addAndGet(memoryInBytes) > totalMemorySizeInBytes) {
-      LOGGER.warn("{} has exceed total memory size", this);
+      LOGGER.debug("{} has exceed total memory size", this);
     }
 
     MetricService.getInstance()

Original file line number	Diff line number	Diff line change
`@@ -59,8 +59,9 @@ public boolean hasEnoughMemory(long memoryTobeAddedInBytes) {`
`59`	`59`
`60`	`60`	`@Override`
`61`	`61`	`public synchronized void addMemoryUsage(long memoryInBytes) {`
	`62`	`+ // May temporarily exceed the max size`
`62`	`63`	`if (memoryUsageInBytes.addAndGet(memoryInBytes) > limitedMemorySizeInBytes.get()) {`
`63`		`- LOGGER.warn("{} has exceed total memory size", this);`
	`64`	`+ LOGGER.debug("{} has exceed total memory size", this);`
`64`	`65`	`}`
`65`	`66`	`}`
`66`	`67`
Original file line number	Diff line number	Diff line change
`@@ -50,8 +50,9 @@ public synchronized boolean hasEnoughMemory(long memoryTobeAddedInBytes) {`
`50`	`50`
`51`	`51`	`@Override`
`52`	`52`	`public synchronized void addMemoryUsage(long memoryInBytes) {`
	`53`	`+ // May temporarily exceed the max size`
`53`	`54`	`if (memoryUsageInBytes.addAndGet(memoryInBytes) > totalMemorySizeInBytes) {`
`54`		`- LOGGER.warn("{} has exceed total memory size", this);`
	`55`	`+ LOGGER.debug("{} has exceed total memory size", this);`
`55`	`56`	`}`
`56`	`57`
`57`	`58`	`MetricService.getInstance()`