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

qiaojialin pushed a commit to branch rel/0.13
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/0.13 by this push:
     new 8ce9a7e  Enhance check statement before writing mlog (#5252)
8ce9a7e is described below

commit 8ce9a7e0afabf68f83143e1be651fac9eb50e241
Author: ZhaoXin <[email protected]>
AuthorDate: Wed Mar 16 14:03:51 2022 +0800

    Enhance check statement before writing mlog (#5252)
---
 server/src/main/java/org/apache/iotdb/db/metadata/MManager.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java 
b/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java
index 0323d09..99aebb4 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java
@@ -934,7 +934,7 @@ public class MManager {
         }
       }
       node = mtree.getDeviceNodeWithAutoCreating(path, sgLevel);
-      if (!(node.isStorageGroup())) {
+      if (!(node.isStorageGroup()) && !isRecovering) {
         logWriter.autoCreateDeviceMNode(new 
AutoCreateDeviceMNodePlan(node.getPartialPath()));
       }
       return node;
@@ -946,7 +946,7 @@ public class MManager {
       }
       // ignore set storage group concurrently
       node = mtree.getDeviceNodeWithAutoCreating(path, sgLevel);
-      if (!(node.isStorageGroup())) {
+      if (!(node.isStorageGroup()) && !isRecovering) {
         logWriter.autoCreateDeviceMNode(new 
AutoCreateDeviceMNodePlan(node.getPartialPath()));
       }
       return node;

Reply via email to