You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2022/05/27 15:08:50 UTC
[incubator-doris] 07/08: [config] Add backend_rpc_timeout_second in FE config (#9779)
This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch dev-1.0.1
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
commit 93f0d50bc66c0a960a04b0de0ec75f6c50c17f6f
Author: pengxiangyu <di...@163.com>
AuthorDate: Fri May 27 21:58:09 2022 +0800
[config] Add backend_rpc_timeout_second in FE config (#9779)
---
docs/en/administrator-guide/config/fe_config.md | 10 ++++++++++
docs/zh-CN/administrator-guide/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 | 3 +++
4 files changed, 25 insertions(+), 3 deletions(-)
diff --git a/docs/en/administrator-guide/config/fe_config.md b/docs/en/administrator-guide/config/fe_config.md
index bfef450d17..6df6807f89 100644
--- a/docs/en/administrator-guide/config/fe_config.md
+++ b/docs/en/administrator-guide/config/fe_config.md
@@ -2181,3 +2181,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/administrator-guide/config/fe_config.md b/docs/zh-CN/administrator-guide/config/fe_config.md
index 0528430a60..0f1f6436d6 100644
--- a/docs/zh-CN/administrator-guide/config/fe_config.md
+++ b/docs/zh-CN/administrator-guide/config/fe_config.md
@@ -2204,3 +2204,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 4098e06073..1b77d3ed43 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 6660d5e63c..45cfac5e2d 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
@@ -1623,4 +1623,7 @@ public class Config extends ConfigBase {
*/
@ConfField(mutable = true)
public static boolean skip_compaction_slower_replica = true;
+
+ @ConfField(mutable = false, masterOnly = true)
+ public static int backend_rpc_timeout_ms = 60000; // 1 min
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org