From dcb840de4b76d621fab683d746a6468d8ddba5db Mon Sep 17 00:00:00 2001
From: Haonan <hhaonan@outlook.com>
Date: Fri, 6 Sep 2024 09:59:42 +0800
Subject: [PATCH] clear AsyncTsFileResourceRecoverTaskList after data region
 recoverd (#13412)

---
 .../java/org/apache/iotdb/db/storageengine/StorageEngine.java | 1 +
 .../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 f9bcb43be60ee..95c1902b95187 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 @@ private void asyncRecoverTsFileResource() {
                 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 6a8a339ccc3cf..7d02ad4eb0a1a 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 List<Callable<Void>> getAsyncTsFileResourceRecoverTaskList() {
     return asyncTsFileResourceRecoverTaskList;
   }
 
+  public void clearAsyncTsFileResourceRecoverTaskList() {
+    asyncTsFileResourceRecoverTaskList.clear();
+  }
+
   /** this class is used to store recovering context. */
   private class DataRegionRecoveryContext {
     /** number of files to be recovered. */