diff --git a/server/src/assembly/resources/conf/iotdb-engine.properties b/server/src/assembly/resources/conf/iotdb-engine.properties index 29ba0690a5afd328d9bfdc6d681c6aa7d1f65f5e..c2b16fd8d1a5afaa153e89252d451eb7504166b0 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 0be9d3d1191be9271708be6769c5be77b4fdf0ff..57619e6ec4d709ccd4b0c5fbbbefe58565ae5264 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 5671b15b6c057d8bf13b266b5616993620bcbfd9..f07d69f1a81fb3cb46f9d5964b69be705f43b6b0 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() {