(iotdb) branch master updated: modify direct buffer memory proportion (#12496)

[tanxinyu]

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

tanxinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new a7aaeb4c75d modify direct buffer memory proportion (#12496)
a7aaeb4c75d is described below

commit a7aaeb4c75d209ab76a5f43447f6b568b9ab62fe
Author: shuwenwei <55970239+shuwen...@users.noreply.github.com>
AuthorDate: Thu May 9 17:52:20 2024 +0800

    modify direct buffer memory proportion (#12496)
---
 .../main/java/org/apache/iotdb/db/conf/IoTDBConfig.java    | 14 +++++++-------
 .../iotdb/db/storageengine/rescon/memory/SystemInfo.java   |  2 +-
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index e46cc2e629e..f3554407dcf 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -214,8 +214,8 @@ public class IoTDBConfig {
   /** Buffer size of each wal node. Unit: byte */
   private int walBufferSize = 32 * 1024 * 1024;
 
-  /** max total wal buffer off heap memory size proportion */
-  private double maxWalBufferOffHeapMemorySizeProportion = 0.5;
+  /** max total direct buffer off heap memory size proportion */
+  private double maxDirectBufferOffHeapMemorySizeProportion = 0.8;
 
   /** Blocking queue capacity of each wal buffer */
   private int walBufferQueueCapacity = 500;
@@ -1825,13 +1825,13 @@ public class IoTDBConfig {
     this.walBufferSize = walBufferSize;
   }
 
-  public double getMaxWalBufferOffHeapMemorySizeProportion() {
-    return maxWalBufferOffHeapMemorySizeProportion;
+  public double getMaxDirectBufferOffHeapMemorySizeProportion() {
+    return maxDirectBufferOffHeapMemorySizeProportion;
   }
 
-  public void setMaxWalBufferOffHeapMemorySizeProportion(
-      double maxWalBufferOffHeapMemorySizeProportion) {
-    this.maxWalBufferOffHeapMemorySizeProportion = 
maxWalBufferOffHeapMemorySizeProportion;
+  public void setMaxDirectBufferOffHeapMemorySizeProportion(
+      double maxDirectBufferOffHeapMemorySizeProportion) {
+    this.maxDirectBufferOffHeapMemorySizeProportion = 
maxDirectBufferOffHeapMemorySizeProportion;
   }
 
   public int getWalBufferQueueCapacity() {
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/memory/SystemInfo.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/memory/SystemInfo.java
index 09bc8d906fa..9074fc65f4d 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/memory/SystemInfo.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/memory/SystemInfo.java
@@ -385,7 +385,7 @@ public class SystemInfo {
             ? Long.MAX_VALUE
             : (long)
                 (config.getMaxOffHeapMemoryBytes()
-                    * config.getMaxWalBufferOffHeapMemorySizeProportion());
+                    * config.getMaxDirectBufferOffHeapMemorySizeProportion());
     memorySizeForMemtable =
         (long)
             (config.getAllocateMemoryForStorageEngine() * 
config.getWriteProportionForMemtable());