This is an automated email from the ASF dual-hosted git repository.
zhaoc 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 f77171f Make bdbje lock timeout configurable (#2676)
f77171f is described below
commit f77171f85d566955c1665a8826d3d49d3d0fb3ec
Author: kangkaisen <[email protected]>
AuthorDate: Mon Jan 6 21:20:36 2020 +0800
Make bdbje lock timeout configurable (#2676)
---
fe/src/main/java/org/apache/doris/common/Config.java | 7 +++++++
.../main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java | 1 +
2 files changed, 8 insertions(+)
diff --git a/fe/src/main/java/org/apache/doris/common/Config.java
b/fe/src/main/java/org/apache/doris/common/Config.java
index abed9ec..4383c82 100644
--- a/fe/src/main/java/org/apache/doris/common/Config.java
+++ b/fe/src/main/java/org/apache/doris/common/Config.java
@@ -184,6 +184,13 @@ public class Config extends ConfigBase {
* you can try to increase this value to decrease the chances of false
timeouts
*/
@ConfField public static int bdbje_heartbeat_timeout_second = 30;
+
+ /*
+ * The lock timeout of bdbje operation
+ * If there are many LockTimeoutException in FE WARN log, you can try to
increase this value
+ */
+ @ConfField
+ public static int bdbje_lock_timeout_second = 1;
/*
* the max txn number which bdbje can rollback when trying to rejoin the
group
diff --git
a/fe/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java
b/fe/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java
index 7ca5569..5ed2ec8 100644
--- a/fe/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java
+++ b/fe/src/main/java/org/apache/doris/journal/bdbje/BDBEnvironment.java
@@ -124,6 +124,7 @@ public class BDBEnvironment {
environmentConfig.setTransactional(true);
environmentConfig.setAllowCreate(true);
environmentConfig.setCachePercent(MEMORY_CACHE_PERCENT);
+ environmentConfig.setLockTimeout(Config.bdbje_lock_timeout_second,
TimeUnit.SECONDS);
if (isElectable) {
Durability durability = new
Durability(getSyncPolicy(Config.master_sync_policy),
getSyncPolicy(Config.replica_sync_policy),
getAckPolicy(Config.replica_ack_policy));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
