From 7e3f8209ee9141015ed57749246a69d346a4e93c Mon Sep 17 00:00:00 2001
From: qiaojialin <646274302@qq.com>
Date: Wed, 2 Sep 2020 21:21:31 +0800
Subject: [PATCH] enlarge force_wal_period_in_ms to 100ms

---
 .../resources/conf/iotdb-engine.properties    |  2 +-
 .../org/apache/iotdb/db/conf/IoTDBConfig.java |  2 +-
 .../manager/MultiFileLogNodeManager.java      | 34 +++++++++----------
 3 files changed, 19 insertions(+), 19 deletions(-)

diff --git a/server/src/assembly/resources/conf/iotdb-engine.properties b/server/src/assembly/resources/conf/iotdb-engine.properties
index 29ba0690a5..c2b16fd8d1 100644
--- a/server/src/assembly/resources/conf/iotdb-engine.properties
+++ b/server/src/assembly/resources/conf/iotdb-engine.properties
@@ -53,7 +53,7 @@ flush_wal_threshold=10000
 # The cycle when insert ahead log is periodically forced to be written to disk(in milliseconds)
 # If force_wal_period_in_ms = 0 it means force insert ahead log to be written to disk after each refreshment
 # Set this parameter to 0 may slow down the ingestion on slow disk.
-force_wal_period_in_ms=10
+force_wal_period_in_ms=100
 
 ####################
 ### Directory Configuration
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 0be9d3d119..57619e6ec4 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
@@ -159,7 +159,7 @@ public class IoTDBConfig {
    * The cycle when write ahead log is periodically forced to be written to disk(in milliseconds) If
    * set this parameter to 0 it means call outputStream.force(true) after every each insert
    */
-  private long forceWalPeriodInMs = 10;
+  private long forceWalPeriodInMs = 100;
 
   /**
    * Size of log buffer in each log node(in byte). If WAL is enabled and the size of a insert plan
diff --git a/server/src/main/java/org/apache/iotdb/db/writelog/manager/MultiFileLogNodeManager.java b/server/src/main/java/org/apache/iotdb/db/writelog/manager/MultiFileLogNodeManager.java
index 5671b15b6c..f07d69f1a8 100644
--- a/server/src/main/java/org/apache/iotdb/db/writelog/manager/MultiFileLogNodeManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/writelog/manager/MultiFileLogNodeManager.java
@@ -46,23 +46,23 @@ public class MultiFileLogNodeManager implements WriteLogNodeManager, IService {
   private ScheduledExecutorService executorService;
   private IoTDBConfig config = IoTDBDescriptor.getInstance().getConfig();
 
-  private final void forceTask(){
-        if (IoTDBDescriptor.getInstance().getConfig().isReadOnly()) {
-          logger.warn("system mode is read-only, the force flush WAL task is stopped");
-          return;
-        }
-        if (Thread.interrupted()) {
-          logger.info("WAL force thread exits.");
-          return;
-        }
-
-        for (WriteLogNode node : nodeMap.values()) {
-          try {
-            node.forceSync();
-          } catch (IOException e) {
-            logger.error("Cannot force {}, because ", node, e);
-          }
-        }
+  private final void forceTask() {
+    if (IoTDBDescriptor.getInstance().getConfig().isReadOnly()) {
+      logger.warn("system mode is read-only, the force flush WAL task is stopped");
+      return;
+    }
+    if (Thread.interrupted()) {
+      logger.info("WAL force thread exits.");
+      return;
+    }
+
+    for (WriteLogNode node : nodeMap.values()) {
+      try {
+        node.forceSync();
+      } catch (IOException e) {
+        logger.error("Cannot force {}, because ", node, e);
+      }
+    }
   }
 
   private MultiFileLogNodeManager() {
-- 
GitLab