From e2a88810b27910e0c59dc61b14d41a1361746518 Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Sat, 25 Jan 2025 14:44:08 +0800 Subject: [PATCH] Update IoTDBDataNodeReceiver.java --- .../db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java | 2 +- 1 file changed, 1 insertion(+), 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 80cbac6a3ef5..6c4c9acf3865 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 @@ -581,7 +581,7 @@ private TSStatus loadTsFileSync(final String dataBaseName, final String fileAbso final LoadTsFileStatement statement = new LoadTsFileStatement(fileAbsolutePath); statement.setDeleteAfterLoad(true); statement.setConvertOnTypeMismatch(true); - statement.setVerifySchema(true); + statement.setVerifySchema(validateTsFile.get()); statement.setAutoCreateDatabase(false); statement.setModel(