(iotdb) branch master updated: Fix flush command failed when dataregion using ratis consensus (#12194)

[haonan]

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

haonan 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 84ea460fe5e Fix flush command failed when dataregion using ratis 
consensus (#12194)
84ea460fe5e is described below

commit 84ea460fe5e10e734aa832decc4dbd81a38a3241
Author: Haonan <hhao...@outlook.com>
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 111de369213..aa4ad28bb57 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
@@ -273,6 +273,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();