[incubator-doris] branch master updated: Make bdbje lock timeout configurable (#2676)

[zhaoc]

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 <kangkai...@apache.org>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org