database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](Config): Remove unused config max_connection_scheduler_threads_num (#24597)

Browse Source
This commit is contained in:
xu tao
2023-09-20 18:11:56 +08:00
committed by GitHub
parent 67e789e025
commit e4b551e2ce
4 changed files with 0 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
docs/en/docs/admin-manual/config/fe-config.md
View File

@ -437,14 +437,6 @@ Default：1024
Maximal number of connections per FE.
#### `max_connection_scheduler_threads_num`
Default：4096
Maximal number of thread in connection-scheduler-pool.
The current strategy is to apply for a separate thread for service when there is a request
#### `check_java_version`
Default：true

8
docs/zh-CN/docs/admin-manual/config/fe-config.md
View File

@ -437,14 +437,6 @@ FE https 使能标志位，false 表示支持 http，true 表示同时支持 htt
每个 FE 的最大连接数
#### `max_connection_scheduler_threads_num`
默认值：4096
查询请求调度器中的最大线程数。
目前的策略是，有请求过来，就为其单独申请一个线程进行服务
#### `check_java_version`
默认值：true

4
fe/fe-common/src/main/java/org/apache/doris/common/Config.java
View File

@ -702,10 +702,6 @@ public class Config extends ConfigBase {
"Maximal number of connections of MySQL server per FE."})
public static int qe_max_connection = 1024;
@ConfField(description = {"MySQL 连接调度线程池的最大线程数。",
"Maximal number of thread in MySQL connection-scheduler-pool."})
public static int max_connection_scheduler_threads_num = 4096;
@ConfField(mutable = true, description = {"Colocate join 每个 instance 的内存 penalty 系数。"
+ "计算方式：`exec_mem_limit / min (query_colocate_join_memory_limit_penalty_factor, instance_num)`",
"Colocate join PlanFragment instance memory limit penalty factor.",

4
fe/fe-core/src/main/java/org/apache/doris/qe/ConnectScheduler.java
View File

@ -18,7 +18,6 @@
package org.apache.doris.qe;
import org.apache.doris.catalog.Env;
import org.apache.doris.common.Config;
import org.apache.doris.common.ThreadPoolManager;
import org.apache.doris.common.util.DebugUtil;
import org.apache.doris.mysql.privilege.PrivPredicate;
@ -32,7 +31,6 @@ import org.apache.logging.log4j.Logger;
import java.util.List;
import java.util.Map;
import java.util.TimerTask;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
@ -47,8 +45,6 @@ public class ConnectScheduler {
private final AtomicInteger nextConnectionId;
private final Map<Integer, ConnectContext> connectionMap = Maps.newConcurrentMap();
private final Map<String, AtomicInteger> connByUser = Maps.newConcurrentMap();
private final ExecutorService executor = ThreadPoolManager.newDaemonCacheThreadPool(
Config.max_connection_scheduler_threads_num, "connect-scheduler-pool", true);
// valid trace id -> query id
private final Map<String, TUniqueId> traceId2QueryId = Maps.newConcurrentMap();