(iotdb) branch master updated: Allows root.__system prefix time series creation #12991

[tanxinyu]

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 8c319778781 Allows root.__system prefix time series creation #12991
8c319778781 is described below

commit 8c319778781719957c32f26ea926963c71bbc8cd
Author: Potato <tanxi...@apache.org>
AuthorDate: Mon Jul 22 18:52:30 2024 +0800

    Allows root.__system prefix time series creation #12991
    
    Signed-off-by: OneSizeFitQuorum <tanxi...@apache.org>
---
 .../db/queryengine/plan/analyze/cache/partition/PartitionCache.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/PartitionCache.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/PartitionCache.java
index 37b9ec9a14f..56934931b8c 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/PartitionCache.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/PartitionCache.java
@@ -75,6 +75,7 @@ import java.util.concurrent.atomic.AtomicLong;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
 
 public class PartitionCache {
+
   private static final Logger logger = 
LoggerFactory.getLogger(PartitionCache.class);
   private static final IoTDBConfig config = 
IoTDBDescriptor.getInstance().getConfig();
   private static final List<String> ROOT_PATH = Arrays.asList("root", "**");
@@ -238,7 +239,8 @@ public class PartitionCache {
         // Try to get database needed to be created from missed device
         Set<String> storageGroupNamesNeedCreated = new HashSet<>();
         for (String devicePath : result.getMissedDevices()) {
-          if (devicePath.startsWith(SchemaConstant.SYSTEM_DATABASE)) {
+          if (devicePath.equals(SchemaConstant.SYSTEM_DATABASE)
+              || devicePath.startsWith(SchemaConstant.SYSTEM_DATABASE + ".")) {
             storageGroupNamesNeedCreated.add(SchemaConstant.SYSTEM_DATABASE);
           } else {
             PartialPath storageGroupNameNeedCreated =
@@ -430,6 +432,7 @@ public class PartitionCache {
   // endregion
 
   // region replicaSet cache
+
   /**
    * get regionReplicaSet from local and confignode
    *