This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new d2cbfea7750 [chore](be) fix typo error in config (#51496)
d2cbfea7750 is described below
commit d2cbfea7750ed72bf083ed0732b7c99346388845
Author: yiguolei <[email protected]>
AuthorDate: Thu Jun 5 14:03:45 2025 +0800
[chore](be) fix typo error in config (#51496)
### What problem does this PR solve?
It is a typo error in the name. Although it is a behavior change, but it
will not affect the online system, because the parameter is not very
important.
---
be/src/common/config.cpp | 6 +++---
be/src/common/config.h | 6 +++---
be/src/runtime/fragment_mgr.cpp | 6 +++---
3 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/be/src/common/config.cpp b/be/src/common/config.cpp
index 43936fc4e76..af4811e00a3 100644
--- a/be/src/common/config.cpp
+++ b/be/src/common/config.cpp
@@ -614,9 +614,9 @@ DEFINE_mInt32(olap_table_sink_send_interval_microseconds,
"1000");
DEFINE_mDouble(olap_table_sink_send_interval_auto_partition_factor, "0.001");
// Fragment thread pool
-DEFINE_Int32(fragment_mgr_asynic_work_pool_thread_num_min, "16");
-DEFINE_Int32(fragment_mgr_asynic_work_pool_thread_num_max, "512");
-DEFINE_Int32(fragment_mgr_asynic_work_pool_queue_size, "4096");
+DEFINE_Int32(fragment_mgr_async_work_pool_thread_num_min, "16");
+DEFINE_Int32(fragment_mgr_async_work_pool_thread_num_max, "512");
+DEFINE_Int32(fragment_mgr_async_work_pool_queue_size, "4096");
// Control the number of disks on the machine. If 0, this comes from the
system settings.
DEFINE_Int32(num_disks, "0");
diff --git a/be/src/common/config.h b/be/src/common/config.h
index 1c1c64ea811..4505d4fe426 100644
--- a/be/src/common/config.h
+++ b/be/src/common/config.h
@@ -650,9 +650,9 @@ DECLARE_mInt32(olap_table_sink_send_interval_microseconds);
DECLARE_mDouble(olap_table_sink_send_interval_auto_partition_factor);
// Fragment thread pool
-DECLARE_Int32(fragment_mgr_asynic_work_pool_thread_num_min);
-DECLARE_Int32(fragment_mgr_asynic_work_pool_thread_num_max);
-DECLARE_Int32(fragment_mgr_asynic_work_pool_queue_size);
+DECLARE_Int32(fragment_mgr_async_work_pool_thread_num_min);
+DECLARE_Int32(fragment_mgr_async_work_pool_thread_num_max);
+DECLARE_Int32(fragment_mgr_async_work_pool_queue_size);
// Control the number of disks on the machine. If 0, this comes from the
system settings.
DECLARE_Int32(num_disks);
diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp
index aad34ab4510..14691849c95 100644
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@@ -320,9 +320,9 @@ FragmentMgr::FragmentMgr(ExecEnv* exec_env)
CHECK(s.ok()) << s.to_string();
s = ThreadPoolBuilder("FragmentMgrAsyncWorkThreadPool")
-
.set_min_threads(config::fragment_mgr_asynic_work_pool_thread_num_min)
-
.set_max_threads(config::fragment_mgr_asynic_work_pool_thread_num_max)
-
.set_max_queue_size(config::fragment_mgr_asynic_work_pool_queue_size)
+
.set_min_threads(config::fragment_mgr_async_work_pool_thread_num_min)
+
.set_max_threads(config::fragment_mgr_async_work_pool_thread_num_max)
+
.set_max_queue_size(config::fragment_mgr_async_work_pool_queue_size)
.build(&_thread_pool);
CHECK(s.ok()) << s.to_string();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
