[refactor]broker rpc timeout configuration parameterization (#10692)

apache · Jul 10, 2022 · a4b6c94 · a4b6c94
1 parent 2cb4939
commit a4b6c94
Show file tree

Hide file tree

Showing 4 changed files with 17 additions and 1 deletion.
diff --git a/docs/en/administrator-guide/config/fe_config.md b/docs/en/administrator-guide/config/fe_config.md
@@ -1456,6 +1456,12 @@ MasterOnly：true
 
 Default broker load timeout
 
+### broker_timeout_ms
+
+Default：10000   （10s）
+
+Default broker RPC timeout
+
 ### load_running_job_num_limit
 
 Default：0

diff --git a/docs/zh-CN/administrator-guide/config/fe_config.md b/docs/zh-CN/administrator-guide/config/fe_config.md
@@ -1465,6 +1465,12 @@ load 最大超时时间，适用于除 stream load 之外的所有类型的加
 
 Broker load 的默认超时时间
 
+### `broker_timeout_ms`
+
+默认值：10000   （10秒）
+
+Broker rpc 的默认超时时间
+
 ### `load_running_job_num_limit`
 
 默认值：0

diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/ClientPool.java b/fe/fe-core/src/main/java/org/apache/doris/common/ClientPool.java
@@ -50,7 +50,7 @@ public class ClientPool {
     }
 
     static GenericKeyedObjectPoolConfig brokerPoolConfig = new GenericKeyedObjectPoolConfig();
-    static int brokerTimeoutMs = 10000;
+    static int brokerTimeoutMs = Config.broker_timeout_ms;
 
     static {
         brokerPoolConfig.setLifo(true);            // set Last In First Out strategy

diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/Config.java b/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
@@ -531,6 +531,10 @@ public class Config extends ConfigBase {
     @ConfField(mutable = true, masterOnly = true)
     public static int broker_load_default_timeout_second = 14400; // 4 hour
 
+    /**
+     * Broker rpc timeout
+     */
+    @ConfField public static int broker_timeout_ms = 10000; // 10s
     /**
      * Default non-streaming mini load timeout
      */