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 {