[iotdb] 01/01: remove_tsfile_after_flush

[haonan]

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

haonan pushed a commit to branch remove_tsfile_after_flush
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 0914a2a0846f6d9fa2b40758754925cf61dce36e
Author: HTHou <hhao...@outlook.com>
AuthorDate: Wed Mar 1 18:22:01 2023 +0800

    remove_tsfile_after_flush
---
 .../iotdb/db/engine/storagegroup/DataRegion.java       | 18 +++++++-----------
 1 file changed, 7 insertions(+), 11 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java 
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java
index 7f2a19a410..fcb431d0ef 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java
@@ -2112,17 +2112,13 @@ public class DataRegion implements IDataRegionForQuery {
     closeQueryLock.writeLock().lock();
     try {
       tsFileProcessor.close();
-      if (tsFileProcessor.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());
-        }
-      } else {
-        
tsFileResourceManager.registerSealedTsFileResource(tsFileProcessor.getTsFileResource());
+      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());
       }
     } finally {
       closeQueryLock.writeLock().unlock();