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

tanxinyu 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 500d4a911dd remove wal files when drop database (#12778)
500d4a911dd is described below

commit 500d4a911dd95fa44f23df7a69da9cf8a60a1b1f
Author: Peng Junzhi <[email protected]>
AuthorDate: Fri Jun 21 02:21:33 2024 -0500

    remove wal files when drop database (#12778)
---
 .../apache/iotdb/db/storageengine/dataregion/wal/WALManager.java   | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

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 c9830ebf2ba..e38d641b944 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
@@ -108,10 +108,13 @@ public class WALManager implements IService {
     WritingMetrics.getInstance().createWALNodeInfoMetrics(applicantUniqueId);
   }
 
-  /** WAL node will be deleted only when using iot consensus protocol. */
+  /** WAL node will be deleted only when using iot series consensus protocol. 
*/
   public void deleteWALNode(String applicantUniqueId) {
     if (config.getWalMode() == WALMode.DISABLE
-        || 
!config.getDataRegionConsensusProtocolClass().equals(ConsensusFactory.IOT_CONSENSUS))
 {
+        || 
!config.getDataRegionConsensusProtocolClass().equals(ConsensusFactory.IOT_CONSENSUS)
+        || !config
+            .getDataRegionConsensusProtocolClass()
+            .equals(ConsensusFactory.IOT_CONSENSUS_V2)) {
       return;
     }
 

Reply via email to