This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch TableModelIngestion
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/TableModelIngestion by this
push:
new 33dc97dce25 qualify database name
33dc97dce25 is described below
commit 33dc97dce25b94550c83a6594d46d680f1b835b2
Author: Tian Jiang <[email protected]>
AuthorDate: Mon Jul 15 10:09:32 2024 +0800
qualify database name
---
.../src/main/java/org/apache/iotdb/commons/partition/DataPartition.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
index 7105e92775e..e684a1cbfb2 100644
---
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
+++
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
@@ -146,6 +146,7 @@ public class DataPartition extends Partition {
public List<TRegionReplicaSet> getDataRegionReplicaSetWithTimeFilter(
String database, IDeviceID deviceId, Filter timeFilter) {
// TODO perfect this interface, @Potato
+ database = PathUtils.qualifyDatabaseName(database);
TSeriesPartitionSlot seriesPartitionSlot =
calculateDeviceGroupId(deviceId);
if (!dataPartitionMap.containsKey(database)
|| !dataPartitionMap.get(database).containsKey(seriesPartitionSlot)) {