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());
}