This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch create_system_database_prefix_device in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c56d930fd9668411640920c7acabb7f80fc102b7 Author: OneSizeFitQuorum <[email protected]> AuthorDate: Mon Jul 22 16:57:23 2024 +0800 finish Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../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 *
