This is an automated email from the ASF dual-hosted git repository.

xingtanzjr 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 538fd5c43c8 Fix empty tsfile resource didn't remove (#11413)
538fd5c43c8 is described below

commit 538fd5c43c82d7db0479eec361206965d700d1b5
Author: Haonan <[email protected]>
AuthorDate: Tue Oct 31 09:36:55 2023 +0800

    Fix empty tsfile resource didn't remove (#11413)
---
 .../apache/iotdb/db/storageengine/dataregion/DataRegion.java   | 10 ++--------
 1 file changed, 2 insertions(+), 8 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
index 0eed0ceefcf..96e32cbe428 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -2054,14 +2054,8 @@ public class DataRegion implements IDataRegionForQuery {
     try {
       tsFileProcessor.close();
       if (tsFileProcessor.isEmpty() || 
tsFileProcessor.getTsFileResource().isEmpty()) {
-        try {
-          
fsFactory.deleteIfExists(tsFileProcessor.getTsFileResource().getTsFile());
-          tsFileManager.remove(tsFileProcessor.getTsFileResource(), 
tsFileProcessor.isSequence());
-        } catch (IOException e) {
-          logger.error(
-              "Remove empty file {} error",
-              
tsFileProcessor.getTsFileResource().getTsFile().getAbsolutePath());
-        }
+        tsFileProcessor.getTsFileResource().remove();
+        tsFileManager.remove(tsFileProcessor.getTsFileResource(), 
tsFileProcessor.isSequence());
       } else {
         
tsFileResourceManager.registerSealedTsFileResource(tsFileProcessor.getTsFileResource());
       }

Reply via email to