This is an automated email from the ASF dual-hosted git repository.
kxiao 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 c2db01037a [refactor](config) rename segcompaction_max_threads (#22468)
c2db01037a is described below
commit c2db01037a225d2d91f02f5663fd55ced611dd10
Author: Kaijie Chen <[email protected]>
AuthorDate: Wed Aug 2 22:35:14 2023 +0800
[refactor](config) rename segcompaction_max_threads (#22468)
---
be/src/common/config.cpp | 6 +++---
be/src/common/config.h | 6 +++---
be/src/olap/olap_server.cpp | 4 ++--
3 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/be/src/common/config.cpp b/be/src/common/config.cpp
index b3abc7fdfb..8a609d713b 100644
--- a/be/src/common/config.cpp
+++ b/be/src/common/config.cpp
@@ -376,9 +376,6 @@ DEFINE_mInt64(compaction_min_size_mbytes, "64");
DEFINE_mInt64(cumulative_compaction_min_deltas, "5");
DEFINE_mInt64(cumulative_compaction_max_deltas, "1000");
-// This config can be set to limit thread number in segcompaction thread pool.
-DEFINE_mInt32(seg_compaction_max_threads, "10");
-
// This config can be set to limit thread number in multiget thread pool.
DEFINE_mInt32(multi_get_max_threads, "10");
@@ -917,6 +914,9 @@ DEFINE_Int32(segcompaction_threshold_segment_num, "10");
// The segment whose row number above the threshold will be compacted during
segcompaction
DEFINE_Int32(segcompaction_small_threshold, "1048576");
+// This config can be set to limit thread number in segcompaction thread pool.
+DEFINE_mInt32(segcompaction_max_threads, "10");
+
// enable java udf and jdbc scannode
DEFINE_Bool(enable_java_support, "true");
diff --git a/be/src/common/config.h b/be/src/common/config.h
index f3527c2947..6bf096399f 100644
--- a/be/src/common/config.h
+++ b/be/src/common/config.h
@@ -424,9 +424,6 @@ DECLARE_mInt64(compaction_min_size_mbytes);
DECLARE_mInt64(cumulative_compaction_min_deltas);
DECLARE_mInt64(cumulative_compaction_max_deltas);
-// This config can be set to limit thread number in segcompaction thread pool.
-DECLARE_mInt32(seg_compaction_max_threads);
-
// This config can be set to limit thread number in multiget thread pool.
DECLARE_mInt32(multi_get_max_threads);
@@ -958,6 +955,9 @@ DECLARE_Int32(segcompaction_threshold_segment_num);
// The segment whose row number above the threshold will be compacted during
segcompaction
DECLARE_Int32(segcompaction_small_threshold);
+// This config can be set to limit thread number in segcompaction thread pool.
+DECLARE_mInt32(segcompaction_max_threads);
+
// enable java udf and jdbc scannode
DECLARE_Bool(enable_java_support);
diff --git a/be/src/olap/olap_server.cpp b/be/src/olap/olap_server.cpp
index afb644d39e..c7862316fb 100644
--- a/be/src/olap/olap_server.cpp
+++ b/be/src/olap/olap_server.cpp
@@ -132,8 +132,8 @@ Status StorageEngine::start_bg_threads() {
if (config::enable_segcompaction) {
ThreadPoolBuilder("SegCompactionTaskThreadPool")
- .set_min_threads(config::seg_compaction_max_threads)
- .set_max_threads(config::seg_compaction_max_threads)
+ .set_min_threads(config::segcompaction_max_threads)
+ .set_max_threads(config::segcompaction_max_threads)
.build(&_seg_compaction_thread_pool);
}
ThreadPoolBuilder("ColdDataCompactionTaskThreadPool")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
