[incubator-doris] branch master updated: [config] Add backend_rpc_timeout_second in FE config (#9779)

[morningman]

This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git


The following commit(s) were added to refs/heads/master by this push:
     new ee1bed46be [config] Add backend_rpc_timeout_second in FE config (#9779)
ee1bed46be is described below

commit ee1bed46be7eba1eef63d02eef44bdbf9fd29770
Author: pengxiangyu <diablo...@163.com>
AuthorDate: Fri May 27 21:58:09 2022 +0800

    [config] Add backend_rpc_timeout_second in FE config (#9779)
---
 docs/en/admin-manual/config/fe-config.md                       | 10 ++++++++++
 docs/zh-CN/admin-manual/config/fe-config.md                    | 10 ++++++++++
 .../src/main/java/org/apache/doris/common/ClientPool.java      |  5 ++---
 fe/fe-core/src/main/java/org/apache/doris/common/Config.java   |  4 ++++
 4 files changed, 26 insertions(+), 3 deletions(-)

diff --git a/docs/en/admin-manual/config/fe-config.md 
b/docs/en/admin-manual/config/fe-config.md
index 43ec0dd6b6..f37e64564e 100644
--- a/docs/en/admin-manual/config/fe-config.md
+++ b/docs/en/admin-manual/config/fe-config.md
@@ -2155,3 +2155,13 @@ Default: 10
 Is it possible to dynamically configure: false
 
 Is it a configuration item unique to the Master FE node: false
+
+### backend_rpc_timeout_ms
+
+ Timeout millisecond for Fe sending rpc request to BE
+
+Default: 60000
+
+Is it possible to dynamically configure: false
+
+Is it a configuration item unique to the Master FE node: true
diff --git a/docs/zh-CN/admin-manual/config/fe-config.md 
b/docs/zh-CN/admin-manual/config/fe-config.md
index c5a3a0200d..b99d1569a1 100644
--- a/docs/zh-CN/admin-manual/config/fe-config.md
+++ b/docs/zh-CN/admin-manual/config/fe-config.md
@@ -2200,3 +2200,13 @@ load 标签清理器将每隔 `label_clean_interval_second` 运行一次以清
 是否可以动态配置：false
 
 是否为 Master FE 节点独有的配置项：false
+
+### backend_rpc_timeout_ms
+
+ FE向BE的BackendService发送rpc请求时的超时时间，单位：毫秒。
+
+默认值：60000
+
+是否可以动态配置：false
+
+是否为 Master FE 节点独有的配置项：true
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
index 674981fc86..9bb0b45589 100644
--- 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
@@ -30,7 +30,6 @@ public class ClientPool {
     static int heartbeatTimeoutMs = FeConstants.heartbeat_interval_second * 
1000;
 
     static GenericKeyedObjectPoolConfig backendConfig = new 
GenericKeyedObjectPoolConfig();
-    static int backendTimeoutMs = 60000; // 1min
 
     static {
         heartbeatConfig.setLifo(true);            // set Last In First Out 
strategy
@@ -68,10 +67,10 @@ public class ClientPool {
             new GenericPool<>("FrontendService", heartbeatConfig, 
heartbeatTimeoutMs,
                     
Config.thrift_server_type.equalsIgnoreCase(ThriftServer.THREADED_SELECTOR));
     public static GenericPool<FrontendService.Client> frontendPool =
-            new GenericPool("FrontendService", backendConfig, backendTimeoutMs,
+            new GenericPool("FrontendService", backendConfig, 
Config.backend_rpc_timeout_ms,
                     
Config.thrift_server_type.equalsIgnoreCase(ThriftServer.THREADED_SELECTOR));
     public static GenericPool<BackendService.Client> backendPool =
-            new GenericPool("BackendService", backendConfig, backendTimeoutMs);
+            new GenericPool("BackendService", backendConfig, 
Config.backend_rpc_timeout_ms);
     public static GenericPool<TPaloBrokerService.Client> brokerPool =
             new GenericPool("TPaloBrokerService", brokerPoolConfig, 
brokerTimeoutMs);
 }
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
index a10974f42a..cff7f2b154 100644
--- 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
@@ -1651,4 +1651,8 @@ public class Config extends ConfigBase {
 
     @ConfField
     public static boolean enable_vectorized_load = false;
+
+    @ConfField(mutable = false, masterOnly = true)
+    public static int backend_rpc_timeout_ms = 60000; // 1 min
+
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org