This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch accelerate_recovery in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f45bc8cc430c874ca349cf54d0617c6bcf69fcee Author: HTHou <[email protected]> AuthorDate: Thu Oct 26 18:04:14 2023 +0800 Execute flush before stop datanode --- .../src/main/java/org/apache/iotdb/db/service/IoTDBShutdownHook.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/IoTDBShutdownHook.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/IoTDBShutdownHook.java index 97d4efa204f..5c67d8d9be4 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/IoTDBShutdownHook.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/IoTDBShutdownHook.java @@ -68,9 +68,7 @@ public class IoTDBShutdownHook extends Thread { WALManager.getInstance().waitAllWALFlushed(); // flush data to Tsfile and remove WAL log files - if (!IoTDBDescriptor.getInstance().getConfig().isClusterMode()) { - StorageEngine.getInstance().syncCloseAllProcessor(); - } + StorageEngine.getInstance().syncCloseAllProcessor(); WALManager.getInstance().deleteOutdatedWALFiles(); // We did this work because the RatisConsensus recovery mechanism is different from other
