(iotdb) branch dev/1.3 updated: Initialize WALNode when DataRegion is created for iotv1 and iotv2 (#14918) (#14921)

[tanxinyu]

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

tanxinyu pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 86bbd3e30af Initialize WALNode when DataRegion is created for iotv1 
and iotv2 (#14918) (#14921)
86bbd3e30af is described below

commit 86bbd3e30afde0a2110b70fd3de7c45c48805919
Author: shuwenwei <55970239+shuwen...@users.noreply.github.com>
AuthorDate: Fri Feb 21 15:56:16 2025 +0800

    Initialize WALNode when DataRegion is created for iotv1 and iotv2 (#14918) 
(#14921)
    
    * Initialize WALNode when DataRegion is created for iotv1 and iotv2
    
    * Initialize WALNode when DataRegion is created for iotv1 and iotv2
---
 .../org/apache/iotdb/db/storageengine/dataregion/DataRegion.java    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
index a86aea4d7f5..07fc70b491f 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -631,6 +631,12 @@ public class DataRegion implements IDataRegionForQuery {
     }
 
     if (StorageEngine.getInstance().isReadyForReadAndWrite()) {
+      if 
(config.getDataRegionConsensusProtocolClass().equals(ConsensusFactory.IOT_CONSENSUS)
+          || config
+              .getDataRegionConsensusProtocolClass()
+              .equals(ConsensusFactory.IOT_CONSENSUS_V2)) {
+        WALManager.getInstance().applyForWALNode(databaseName + 
FILE_NAME_SEPARATOR + dataRegionId);
+      }
       logger.info("The data region {}[{}] is created successfully", 
databaseName, dataRegionId);
     } else {
       logger.info("The data region {}[{}] is recovered successfully", 
databaseName, dataRegionId);