This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 70f18ccc4e2 Load Tsfile Tool: load does not delete the source tsfile
by default (#12549)
70f18ccc4e2 is described below
commit 70f18ccc4e28083dd751453555c3b5bab90869d2
Author: Zhijia Cao <[email protected]>
AuthorDate: Mon May 20 17:00:25 2024 +0800
Load Tsfile Tool: load does not delete the source tsfile by default (#12549)
---
.../iotdb/db/queryengine/plan/statement/crud/LoadTsFileStatement.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/LoadTsFileStatement.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/LoadTsFileStatement.java
index ad015cdaccc..06fa870aee6 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/LoadTsFileStatement.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/LoadTsFileStatement.java
@@ -53,7 +53,7 @@ public class LoadTsFileStatement extends Statement {
this.file = new File(filePath);
this.databaseLevel =
IoTDBDescriptor.getInstance().getConfig().getDefaultStorageGroupLevel();
this.verifySchema = true;
- this.deleteAfterLoad = true;
+ this.deleteAfterLoad = false;
this.autoCreateDatabase =
IoTDBDescriptor.getInstance().getConfig().isAutoCreateSchemaEnabled();
this.tsFiles = new ArrayList<>();
this.resources = new ArrayList<>();
@@ -78,7 +78,7 @@ public class LoadTsFileStatement extends Statement {
this.file = null;
this.databaseLevel =
IoTDBDescriptor.getInstance().getConfig().getDefaultStorageGroupLevel();
this.verifySchema = true;
- this.deleteAfterLoad = true;
+ this.deleteAfterLoad = false;
this.autoCreateDatabase =
IoTDBDescriptor.getInstance().getConfig().isAutoCreateSchemaEnabled();
this.tsFiles = new ArrayList<>();
this.resources = new ArrayList<>();