You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2024/05/25 02:41:42 UTC

(iotdb) branch ban-auto-create-db created (now 27b3280ac46)

This is an automated email from the ASF dual-hosted git repository.

yongzao pushed a change to branch ban-auto-create-db
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 27b3280ac46 Update ClusterPartitionFetcher.java

This branch includes the following new commits:

     new 27b3280ac46 Update ClusterPartitionFetcher.java

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: Update ClusterPartitionFetcher.java

Posted by yo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

yongzao pushed a commit to branch ban-auto-create-db
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 27b3280ac46cdc8f692e74e2536d33cfc2ee3b2b
Author: YongzaoDan <53...@qq.com>
AuthorDate: Sat May 25 10:41:28 2024 +0800

    Update ClusterPartitionFetcher.java
---
 .../iotdb/db/queryengine/plan/analyze/ClusterPartitionFetcher.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/ClusterPartitionFetcher.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/ClusterPartitionFetcher.java
index 1069aca33b8..e76973c516b 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/ClusterPartitionFetcher.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/ClusterPartitionFetcher.java
@@ -254,7 +254,8 @@ public class ClusterPartitionFetcher implements IPartitionFetcher {
       List<DataPartitionQueryParam> dataPartitionQueryParams, String userName) {
 
     Map<String, List<DataPartitionQueryParam>> splitDataPartitionQueryParams =
-        splitDataPartitionQueryParam(dataPartitionQueryParams, true, userName);
+        splitDataPartitionQueryParam(
+            dataPartitionQueryParams, config.isAutoCreateSchemaEnabled(), userName);
     DataPartition dataPartition = partitionCache.getDataPartition(splitDataPartitionQueryParams);
 
     if (null == dataPartition) {