This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new a6e5d20fc60 branch-4.0: [fix](flush) Fix the issue of incorrect
calculation of the number of flush threads in cloud mode #59524 (#60082)
a6e5d20fc60 is described below
commit a6e5d20fc60fdad306352a516b0133e57a23c61f
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jan 21 05:39:23 2026 +0800
branch-4.0: [fix](flush) Fix the issue of incorrect calculation of the
number of flush threads in cloud mode #59524 (#60082)
Cherry-picked from #59524
Co-authored-by: Refrain <[email protected]>
---
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 6ab5c82806b..9b507bbd537 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);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
