This is an automated email from the ASF dual-hosted git repository.
jiangtian 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 d1270deaf00 setup (#16752)
d1270deaf00 is described below
commit d1270deaf0080ab7b2e297eb02afd346dd16f331
Author: VGalaxies <[email protected]>
AuthorDate: Mon Nov 17 10:42:50 2025 +0800
setup (#16752)
---
.../db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
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 eb36ddeb19c..2ab134b3e40 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
@@ -97,6 +97,7 @@ import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
+import java.nio.BufferUnderflowException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
@@ -306,10 +307,17 @@ public class LoadTsFileAnalyzer implements AutoCloseable {
// just return false to STOP the analysis process,
// the real result on the conversion will be set in the analysis.
return false;
+ } catch (BufferUnderflowException e) {
+ LOGGER.warn(
+ "The file {} is not a valid tsfile. Please check the input file.",
tsFile.getPath(), e);
+ throw new SemanticException(
+ String.format(
+ "The file %s is not a valid tsfile. Please check the input
file.",
+ tsFile.getPath()));
} catch (Exception e) {
final String exceptionMessage =
String.format(
- "The file %s is not a valid tsfile. Please check the input
file. Detail: %s",
+ "Loading file %s failed. Detail: %s",
tsFile.getPath(), e.getMessage() == null ?
e.getClass().getName() : e.getMessage());
LOGGER.warn(exceptionMessage, e);
analysis.setFinishQueryAfterAnalyze(true);