This is an automated email from the ASF dual-hosted git repository.

spricoder pushed a commit to branch feature/memory_auto
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/feature/memory_auto by this 
push:
     new 2981b6296a1 Change higher and lower
2981b6296a1 is described below

commit 2981b6296a148683ed05807862ed0def47608669
Author: spricoder <[email protected]>
AuthorDate: Sat Feb 22 14:50:02 2025 +0800

    Change higher and lower
---
 .../src/main/java/org/apache/iotdb/commons/memory/MemoryManager.java  | 4 ++--
 .../main/java/org/apache/iotdb/commons/memory/MemoryRuntimeAgent.java | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/MemoryManager.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/MemoryManager.java
index 7b7587a76c2..5429b61c582 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/MemoryManager.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/MemoryManager.java
@@ -578,8 +578,8 @@ public class MemoryManager {
       }
       if (higherMemoryManager != null && 
!higherMemoryManager.equals(lowerMemoryManager)) {
         // transfer
-        long transferSize = higherMemoryManager.shrink();
-        lowerMemoryManager.expandTotalMemorySizeInBytes(transferSize);
+        long transferSize = lowerMemoryManager.shrink();
+        higherMemoryManager.expandTotalMemorySizeInBytes(transferSize);
         LOGGER.info(
             "Transfer Memory Size {} from {} to {}",
             transferSize,
diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/MemoryRuntimeAgent.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/MemoryRuntimeAgent.java
index bcbde93aabe..40e5e5aa478 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/MemoryRuntimeAgent.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/MemoryRuntimeAgent.java
@@ -43,7 +43,7 @@ public class MemoryRuntimeAgent implements IService {
       new MemoryPeriodicalJobExecutor(
           IoTDBThreadPoolFactory.newSingleThreadScheduledExecutor(
               ThreadName.MEMORY_PERIODICAL_JOB_EXECUTOR.getName()),
-          20);
+          MEMORY_CHECK_INTERVAL_IN_S);
 
   @Override
   public void start() throws StartupException {

Reply via email to