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 <[email protected]>
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) {

Reply via email to