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 9ffca1c7997 Load: skipping instead of throwing exceptions when loading 
empty tsfiles (#11261)
9ffca1c7997 is described below

commit 9ffca1c7997463bf4a3b2c01719e3a654225e336
Author: ppppoooo <[email protected]>
AuthorDate: Tue Oct 10 16:33:21 2023 +0800

    Load: skipping instead of throwing exceptions when loading empty tsfiles 
(#11261)
---
 .../iotdb/db/queryengine/plan/analyze/LoadTsfileAnalyzer.java  | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsfileAnalyzer.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsfileAnalyzer.java
index 6a64e7cc7e1..900b7a2d7d9 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsfileAnalyzer.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/LoadTsfileAnalyzer.java
@@ -126,10 +126,12 @@ public class LoadTsfileAnalyzer {
         if (LOGGER.isWarnEnabled()) {
           LOGGER.warn(String.format("TsFile %s is empty.", tsFile.getPath()));
         }
-        throw new SemanticException(
-            String.format(
-                "TsFile %s is empty, please check it be flushed to disk 
correctly.",
-                tsFile.getPath()));
+        if (LOGGER.isInfoEnabled()) {
+          LOGGER.info(
+              "Load - Analysis Stage: {}/{} tsfiles have been analyzed, 
progress: {}%",
+              i + 1, tsfileNum, String.format("%.3f", (i + 1) * 100.00 / 
tsfileNum));
+        }
+        continue;
       }
 
       try {

Reply via email to