This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch CannotFetchSchemaPartition in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8fad7cd0c7af35d76be994992fad15eba14be503 Author: JackieTien97 <[email protected]> AuthorDate: Fri Aug 18 11:58:28 2023 +0800 Allow in DevicePath --- .../apache/iotdb/confignode/manager/ConfigManager.java | 15 ++++++--------- .../plan/analyze/cache/partition/PartitionCache.java | 10 ++++++---- 2 files changed, 12 insertions(+), 13 deletions(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java index f1f6cbdef2f..3bb62c2e554 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java @@ -689,15 +689,12 @@ public class ConfigManager implements IManager { // Build GetOrCreateSchemaPartitionPlan Map<String, List<TSeriesPartitionSlot>> partitionSlotsMap = new HashMap<>(); for (String devicePath : devicePaths) { - if (!devicePath.contains("*")) { - // Only check devicePaths that without "*" - for (String database : databases) { - if (PathUtils.isStartWith(devicePath, database)) { - partitionSlotsMap - .computeIfAbsent(database, key -> new ArrayList<>()) - .add(getPartitionManager().getSeriesPartitionSlot(devicePath)); - break; - } + for (String database : databases) { + if (PathUtils.isStartWith(devicePath, database)) { + partitionSlotsMap + .computeIfAbsent(database, key -> new ArrayList<>()) + .add(getPartitionManager().getSeriesPartitionSlot(devicePath)); + break; } } } 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 478033b335e..32935d45c1a 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 @@ -314,10 +314,12 @@ public class PartitionCache { List<String> devicePaths, boolean tryToFetch, boolean isAutoCreate) { - // miss when devicePath contains * - for (String devicePath : devicePaths) { - if (devicePath.contains("*")) { - return; + if (!isAutoCreate) { + // miss when devicePath contains * + for (String devicePath : devicePaths) { + if (devicePath.contains("*")) { + return; + } } } // first try to hit database in fast-fail way
