add

Author: 0AyanamiRei

be/src/olap/storage_engine.cpp

@@ -298,7 +298,13 @@ Status StorageEngine::_open() {
     auto dirs = get_stores();
     RETURN_IF_ERROR(load_data_dirs(dirs));
 
-    _disk_num = cast_set<int>(dirs.size());
+    if (config::is_cloud_mode()) {
+        // (Refrian) In cloud mode, the number of flush threads currently depends on the file cache setting.
+        // A more precise adaptive algorithm is needed.
+        _disk_num = cast_set<int>(io::FileCacheFactory::instance()->get_cache_instance_size());
+    } else {
+        _disk_num = cast_set<int>(dirs.size());
+    }
     _memtable_flush_executor = std::make_unique<MemTableFlushExecutor>();
     _memtable_flush_executor->init(_disk_num);
 

be/src/olap/storage_engine.h

@@ -177,6 +177,8 @@ class BaseStorageEngine {
 
     int64_t _memory_limitation_bytes_for_schema_change;
 
+    // The value depends on the number of `storage_root_path` parameters in non-cloud mode,
+    // or the number of `file_cache_path` parameters in cloud mode.
     int _disk_num {-1};
 
     std::shared_ptr<StreamLoadRecorder> _stream_load_recorder;