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)) {

Reply via email to