From 588b1b06b88c6ddbfab5b626eac5dc462b402817 Mon Sep 17 00:00:00 2001 From: Calvin Kirs Date: Mon, 30 Oct 2023 12:28:07 +0800 Subject: [PATCH] Fix meaningless thread creation every time checkpoint mysql load --- .../java/org/apache/doris/load/loadv2/MysqlLoadManager.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/MysqlLoadManager.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/MysqlLoadManager.java index e584cdea767fccd..bbf95d492b5aa6b 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/MysqlLoadManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/MysqlLoadManager.java @@ -139,14 +139,15 @@ public boolean isExpired() { private final Map loadContextMap = new ConcurrentHashMap<>(); private EvictingQueue failedRecords; - private ScheduledExecutorService periodScheduler = Executors.newScheduledThreadPool(1, - new CustomThreadFactory("mysql-load-fail-record-cleaner")); + private ScheduledExecutorService periodScheduler ; public MysqlLoadManager(TokenManager tokenManager) { this.tokenManager = tokenManager; } public void start() { + this.periodScheduler = Executors.newScheduledThreadPool(1, + new CustomThreadFactory("mysql-load-fail-record-cleaner")); int poolSize = Config.mysql_load_thread_pool; // MySqlLoad pool can accept 4 + 4 * 5 = 24 requests by default. this.mysqlLoadPool = ThreadPoolManager.newDaemonFixedThreadPool(poolSize, poolSize * 5,