(iotdb) branch rc/1.3.3 updated: clear AsyncTsFileResourceRecoverTaskList after data region recoverd (#13412) (#13430)

[jiangtian]

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

jiangtian pushed a commit to branch rc/1.3.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rc/1.3.3 by this push:
     new cac8fc16f45 clear AsyncTsFileResourceRecoverTaskList after data region 
recoverd (#13412) (#13430)
cac8fc16f45 is described below

commit cac8fc16f4589cceb3fead02607b43c9a1010e31
Author: Haonan <hhao...@outlook.com>
AuthorDate: Fri Sep 6 14:11:57 2024 +0800

    clear AsyncTsFileResourceRecoverTaskList after data region recoverd 
(#13412) (#13430)
---
 .../main/java/org/apache/iotdb/db/storageengine/StorageEngine.java    | 1 +
 .../java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java | 4 ++++
 2 files changed, 5 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
index f9bcb43be60..95c1902b951 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
@@ -366,6 +366,7 @@ public class StorageEngine implements IService {
                 for (Callable<Void> task : asyncTsFileResourceRecoverTasks) {
                   task.call();
                 }
+                dataRegion.clearAsyncTsFileResourceRecoverTaskList();
                 dataRegion.initCompactionSchedule();
                 return null;
               };
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 6a8a339ccc3..7d02ad4eb0a 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
@@ -391,6 +391,10 @@ public class DataRegion implements IDataRegionForQuery {
     return asyncTsFileResourceRecoverTaskList;
   }
 
+  public void clearAsyncTsFileResourceRecoverTaskList() {
+    asyncTsFileResourceRecoverTaskList.clear();
+  }
+
   /** this class is used to store recovering context. */
   private class DataRegionRecoveryContext {
     /** number of files to be recovered. */