(iotdb) branch dev/1.3 updated: [To dev/1.3] Load: Deleted the unnecessary auto-creation (#16624) (#16628)

[justinchen]

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

justinchen pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new d866e34b1b1 [To dev/1.3] Load: Deleted the unnecessary auto-creation 
(#16624) (#16628)
d866e34b1b1 is described below

commit d866e34b1b18ca7843aca1f59ce28b0456d38582
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Oct 23 19:56:01 2025 +0800

    [To dev/1.3] Load: Deleted the unnecessary auto-creation (#16624) (#16628)
    
    * fix
    
    * remove-uls
---
 .../iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java | 3 ++-
 .../iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java    | 4 ++++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
index 5965d362564..de3ae290e89 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
@@ -487,7 +487,8 @@ public class IoTDBDataNodeReceiver extends 
IoTDBFileReceiver {
     statement.setDeleteAfterLoad(true);
     statement.setConvertOnTypeMismatch(true);
     statement.setVerifySchema(validateTsFile.get());
-    statement.setAutoCreateDatabase(false);
+    statement.setAutoCreateDatabase(
+        IoTDBDescriptor.getInstance().getConfig().isAutoCreateSchemaEnabled());
 
     return executeStatementAndClassifyExceptions(statement);
   }
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java
index 555374af1b1..765300a65c1 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java
@@ -722,6 +722,10 @@ public class LoadTsFileAnalyzer implements AutoCloseable {
 
           for (final String databaseName : resp.getDatabaseInfoMap().keySet()) 
{
             schemaCache.addAlreadySetDatabase(new PartialPath(databaseName));
+            databasesNeededToBeSet.removeIf(
+                database ->
+                    database.startsWith(databaseName)
+                        || databaseName.startsWith(database.getFullPath()));
           }
         } catch (IOException | TException | ClientManagerException e) {
           throw new LoadFileException(e);