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")