From 1d7e99fd576d37b8929292cb21f74ed24c48a686 Mon Sep 17 00:00:00 2001
From: Refrain <113875799+0AyanamiRei@users.noreply.github.com>
Date: Wed, 21 Jan 2026 02:13:39 +0800
Subject: [PATCH] [fix](flush) Fix the issue of incorrect calculation of the
 number of flush threads in cloud mode (#59524)

### What problem does this PR solve?

Issue Number: close #xxx

Related PR: #xxx https://github.com/apache/doris/pull/38789
---
 be/src/runtime/workload_group/workload_group.cpp | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/be/src/runtime/workload_group/workload_group.cpp b/be/src/runtime/workload_group/workload_group.cpp
index 6ab5c82806bd06..9b507bbd537e48 100644
--- a/be/src/runtime/workload_group/workload_group.cpp
+++ b/be/src/runtime/workload_group/workload_group.cpp
@@ -422,7 +422,12 @@ WorkloadGroupInfo WorkloadGroupInfo::parse_topic_info(
     int num_disk = 1;
     int num_cpus = 1;
 #ifndef BE_TEST
-    num_disk = ExecEnv::GetInstance()->storage_engine().get_disk_num();
+    if (config::is_cloud_mode()) {
+        // In cloud mode, use cache disk count instead of data disk count
+        num_disk = cast_set<int>(io::FileCacheFactory::instance()->get_cache_instance_size());
+    } else {
+        num_disk = ExecEnv::GetInstance()->storage_engine().get_disk_num();
+    }
     num_cpus = std::thread::hardware_concurrency();
 #endif
     num_disk = std::max(1, num_disk);