This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 9421ffce517935184b3116e2a9d1174b0d2a433b 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 10373e42ee..b38061a3fc 100644 --- a/be/src/common/config.cpp +++ b/be/src/common/config.cpp @@ -372,9 +372,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"); @@ -913,6 +910,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 e5f3e59c52..ff317c7c80 100644 --- a/be/src/common/config.h +++ b/be/src/common/config.h @@ -419,9 +419,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); @@ -953,6 +950,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 705d803929..dc894419a9 100644 --- a/be/src/olap/olap_server.cpp +++ b/be/src/olap/olap_server.cpp @@ -133,8 +133,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]
