[iotdb] 02/02: add cache recover

[he...@apache.org]

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

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

commit 024cc1b4c8d003b971f2cfb3111b2e20b99f9c0b
Author: HeimingZ <zh...@qq.com>
AuthorDate: Wed May 24 16:42:56 2023 +0800

    add cache recover
---
 .../main/java/org/apache/iotdb/db/engine/StorageEngine.java    | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
index 0021dcfa6f1..c122b79c444 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
@@ -63,6 +63,7 @@ import org.apache.iotdb.db.utils.UpgradeUtils;
 import org.apache.iotdb.db.wal.WALManager;
 import org.apache.iotdb.db.wal.exception.WALException;
 import org.apache.iotdb.db.wal.recover.WALRecoverManager;
+import org.apache.iotdb.os.cache.CacheRecoverTask;
 import org.apache.iotdb.rpc.RpcUtils;
 import org.apache.iotdb.rpc.TSStatusCode;
 import org.apache.iotdb.tsfile.exception.write.PageException;
@@ -273,6 +274,15 @@ public class StorageEngine implements IService {
         futures.add(cachedThreadPool.submit(recoverDataRegionTask));
       }
     }
+    // submit object storage cache recover task
+    if (config.isEnableObjectStorage()) {
+      futures.add(
+          cachedThreadPool.submit(
+              () -> {
+                new CacheRecoverTask().run();
+                return null;
+              }));
+    }
   }
 
   /** get StorageGroup -> DataRegionIdList map from data/system directory. */