fix empty resource recovered from wal (apache#11452)

l2280212 · Nov 7, 2023 · 3244255 · 3244255
1 parent aa99a22
commit 3244255
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java b/...-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -730,6 +730,10 @@ private void recoverUnsealedTsFileCallBack(UnsealedTsFileRecoverPerformer recove
         } catch (IOException e) {
           logger.error("Fail to close TsFile {} when recovering", tsFileResource.getTsFile(), e);
         }
+        if (!TsFileValidator.getInstance().validateTsFile(tsFileResource)) {
+          tsFileResource.remove();
+          return;
+        }
         updateLastFlushTime(tsFileResource, isSeq);
         tsFileResourceManager.registerSealedTsFileResource(tsFileResource);
         FileMetrics.getInstance()