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();
