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

haonan pushed a commit to branch rc/1.3.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit fbc62d386cf230b54d1cea22c32ca8ca69da3e3f
Author: Haonan <[email protected]>
AuthorDate: Mon Mar 18 17:47:06 2024 +0800

    Fix flush command failed when dataregion using ratis consensus (#12194)
---
 .../org/apache/iotdb/db/storageengine/dataregion/wal/WALManager.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/WALManager.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/WALManager.java
index 2268b745121..cb571cadcf1 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/WALManager.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/WALManager.java
@@ -266,6 +266,9 @@ public class WALManager implements IService {
   }
 
   public void syncDeleteOutdatedFilesInWALNodes() {
+    if (config.getWalMode() == WALMode.DISABLE || walDeleteThread == null) {
+      return;
+    }
     Future<?> future = 
walDeleteThread.submit(this::deleteOutdatedFilesInWALNodes);
     try {
       future.get();

Reply via email to