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

luoluoyuyu · web-flow · commit 7d3efb279ec7 · 2025-05-19T10:26:04.000+08:00
(cherry picked from commit 8ff0120)
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
@@ -200,7 +200,8 @@ private TSStatus loadTsFile(final Pair<String, Boolean> filePair) throws FileNot
     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);
   }
 

Original file line number	Diff line number	Diff line change
`@@ -200,7 +200,8 @@ private TSStatus loadTsFile(final Pair<String, Boolean> filePair) throws FileNot`
`200`	`200`	`statement.setDeleteAfterLoad(true);`
`201`	`201`	`statement.setConvertOnTypeMismatch(true);`
`202`	`202`	`statement.setVerifySchema(isVerify);`
`203`		`- statement.setAutoCreateDatabase(false);`
	`203`	`+ statement.setAutoCreateDatabase(`
	`204`	`+ IoTDBDescriptor.getInstance().getConfig().isAutoCreateSchemaEnabled());`
`204`	`205`	`return executeStatement(filePair.getRight() ? new PipeEnrichedStatement(statement) : statement);`
`205`	`206`	`}`
`206`	`207`