This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev/1.3 by this push:
new 0de15a76de8 Load: check if the DataRegion is Deleted before loading
the new tsfile (#15346) (#15368)
0de15a76de8 is described below
commit 0de15a76de8666e34ede090eb2e97e37aed1e26b
Author: Itami Sho <[email protected]>
AuthorDate: Mon Apr 21 19:39:01 2025 +0800
Load: check if the DataRegion is Deleted before loading the new tsfile
(#15346) (#15368)
(cherry picked from commit 21b0fb7cea31c7ef6ee12fb0d1f130b8b72e904e)
---
.../org/apache/iotdb/db/storageengine/dataregion/DataRegion.java | 6 ++++++
1 file changed, 6 insertions(+)
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 a734112c56e..1dc97aa2776 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
@@ -2920,6 +2920,12 @@ public class DataRegion implements IDataRegionForQuery {
writeLock("loadNewTsFile");
try {
+ if (deleted) {
+ logger.info(
+ "Won't load TsFile {}, because region is deleted",
+ tsfileToBeInserted.getAbsolutePath());
+ return;
+ }
newTsFileResource.setSeq(false);
final String newFileName =
getNewTsFileName(
