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 {