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;