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 10:52:35 UTC
(iotdb) branch master updated: Allows root.__system prefix time series creation #12991
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 <ta...@apache.org>
AuthorDate: Mon Jul 22 18:52:30 2024 +0800
Allows root.__system prefix time series creation #12991
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
*