Load: Add check for BufferUnderflowException (#12690)

Co-authored-by: xz m <[email protected]>
apache · Jun 11, 2024 · c2f3640 · c2f3640
1 parent 3846563
commit c2f3640
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/...tanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsfileAnalyzer.java b/...tanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsfileAnalyzer.java
@@ -82,6 +82,7 @@
 
 import java.io.File;
 import java.io.IOException;
+import java.nio.BufferUnderflowException;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
@@ -177,6 +178,13 @@ public Analysis analyzeFileByFile() {
             String.format("TsFile %s is empty or incomplete.", tsFile.getPath()));
       } catch (AuthException e) {
         return createFailAnalysisForAuthException(e);
+      } 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) {
         LOGGER.warn("Parse file {} to resource error.", tsFile.getPath(), e);
         throw new SemanticException(