diff --git a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java index 689c85940dfc39..98a54c713c8717 100644 --- a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java +++ b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java @@ -3206,6 +3206,10 @@ public static int metaServiceRpcRetryTimes() { + "model is set to 300 times, which is approximately 5 minutes by default."}) public static int auto_start_wait_to_resume_times = 300; + @ConfField(description = {"Get tablet stat task的最大并发数。", + "Maximal concurrent num of get tablet stat job."}) + public static int max_get_tablet_stat_task_threads_num = 16; + // ATTN: DONOT add any config not related to cloud mode here // ATTN: DONOT add any config not related to cloud mode here // ATTN: DONOT add any config not related to cloud mode here diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/CloudTabletStatMgr.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/CloudTabletStatMgr.java index b839fab3c158a2..309b433572c942 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/CloudTabletStatMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/CloudTabletStatMgr.java @@ -51,7 +51,8 @@ public class CloudTabletStatMgr extends MasterDaemon { // <(dbId, tableId) -> OlapTable.Statistics> private volatile Map, OlapTable.Statistics> cloudTableStatsMap = new HashMap<>(); - private static final ExecutorService GET_TABLET_STATS_THREAD_POOL = Executors.newFixedThreadPool(16); + private static final ExecutorService GET_TABLET_STATS_THREAD_POOL = Executors.newFixedThreadPool( + Config.max_get_tablet_stat_task_threads_num); public CloudTabletStatMgr() { super("cloud tablet stat mgr", Config.tablet_stat_update_interval_second * 1000);