[iotdb] branch benchants_branch updated: Change walMode, max_wal_nodes_num, wal_async_mode_fsync_delay_in_ms and wal_buffer_queue_capacity

[jackietien]

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

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


The following commit(s) were added to refs/heads/benchants_branch by this push:
     new 5caf93a13e2 Change walMode, max_wal_nodes_num, 
wal_async_mode_fsync_delay_in_ms and wal_buffer_queue_capacity
     new 95db800a25a Merge branch 'benchants_branch' of 
https://github.com/apache/iotdb into benchants_branch
5caf93a13e2 is described below

commit 5caf93a13e2da95dc0428db561ea1626edc53795
Author: JackieTien97 <jackietie...@gmail.com>
AuthorDate: Fri Jun 9 16:10:38 2023 +0800

    Change walMode, max_wal_nodes_num, wal_async_mode_fsync_delay_in_ms and 
wal_buffer_queue_capacity
---
 server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java 
b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index fdf028972c7..3ae3ac0bcca 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -185,13 +185,13 @@ public class IoTDBConfig {
   private volatile WALMode walMode = WALMode.ASYNC;
 
   /** Max number of wal nodes, each node corresponds to one wal directory */
-  private int maxWalNodesNum = 0;
+  private int maxWalNodesNum = 9;
 
   /**
    * Duration a wal flush operation will wait before calling fsync in the 
async mode. Unit:
    * millisecond
    */
-  private volatile long walAsyncModeFsyncDelayInMs = 1_000;
+  private volatile long walAsyncModeFsyncDelayInMs = 3_000;
 
   /**
    * Duration a wal flush operation will wait before calling fsync in the sync 
mode. Unit:
@@ -203,7 +203,7 @@ public class IoTDBConfig {
   private int walBufferSize = 32 * 1024 * 1024;
 
   /** Blocking queue capacity of each wal buffer */
-  private int walBufferQueueCapacity = 500;
+  private int walBufferQueueCapacity = 5000;
 
   /** Size threshold of each wal file. Unit: byte */
   private volatile long walFileSizeThresholdInByte = 30 * 1024 * 1024L;