You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2024/07/22 08:57:36 UTC
(iotdb) branch create_system_database_prefix_device created (now c56d930fd96)
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch create_system_database_prefix_device
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at c56d930fd96 finish
This branch includes the following new commits:
new c56d930fd96 finish
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: finish
Posted by ta...@apache.org.
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 <ta...@apache.org>
AuthorDate: Mon Jul 22 16:57:23 2024 +0800
finish
Signed-off-by: OneSizeFitQuorum <ta...@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
*