(iotdb) branch dev/1.3 updated: Async Load: Set the database name null when appropriate & Enable auto-creation of the database by reading the isAutoCreateSchemaEnabled flag from config (#15489) (#15520)

[rong]

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

rong 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 7d3efb279ec Async Load: Set the database name null when appropriate & 
Enable auto-creation of the database by reading the isAutoCreateSchemaEnabled 
flag from config (#15489) (#15520)
7d3efb279ec is described below

commit 7d3efb279ec794bfb08c7870ea926148fb0126ab
Author: Zhenyu Luo <luoluoyuyu2...@gmail.com>
AuthorDate: Mon May 19 10:26:04 2025 +0800

    Async Load: Set the database name null when appropriate & Enable 
auto-creation of the database by reading the isAutoCreateSchemaEnabled flag 
from config (#15489) (#15520)
    
    (cherry picked from commit 8ff0120493625760f44a54b88b6ec5914f81ed37)
---
 .../iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java
index 65665f5e3d4..b1f950321dd 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java
@@ -200,7 +200,8 @@ public class ActiveLoadTsFileLoader {
     statement.setDeleteAfterLoad(true);
     statement.setConvertOnTypeMismatch(true);
     statement.setVerifySchema(isVerify);
-    statement.setAutoCreateDatabase(false);
+    statement.setAutoCreateDatabase(
+        IoTDBDescriptor.getInstance().getConfig().isAutoCreateSchemaEnabled());
     return executeStatement(filePair.getRight() ? new 
PipeEnrichedStatement(statement) : statement);
   }