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

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

Browse Source
This commit is contained in:
jiafeng.zhang
2022-07-09 06:27:02 +08:00
committed by GitHub
parent ed4b2140d7
commit 3229730933
4 changed files with 17 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fe/fe-core/src/main/java/org/apache/doris/common/ClientPool.java
View File

@ -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

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

@ -547,6 +547,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
*/