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

dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git

commit 3c6e35f0824594a6152774d32ab63d7d8690ceb6
Author: huanghaibin <[email protected]>
AuthorDate: Wed Sep 18 19:51:15 2024 +0800

    [improve](cloud-mow) make the waiting time on getDeleteBitmapUpdateLock 
more reasonable (#40341)
    
    now the expired time of mow delete bitmap lock on ms is 60s, so fe
    should try to wait at most 60s to getDeleteBitmapUpdateLock.
---
 .../apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java    | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
 
b/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
index e64188b7c22..d06369c49e1 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
@@ -792,8 +792,8 @@ public class CloudGlobalTransactionMgr implements 
GlobalTransactionMgrIface {
                     LOG.warn("ignore get delete bitmap lock exception, 
transactionId={}, retryTime={}",
                             transactionId, retryTime, e);
                 }
-                // sleep random millis [20, 200] ms, avoid txn conflict
-                int randomMillis = 20 + (int) (Math.random() * (200 - 20));
+                // sleep random millis [20, 300] ms, avoid txn conflict
+                int randomMillis = 20 + (int) (Math.random() * (300 - 20));
                 if (LOG.isDebugEnabled()) {
                     LOG.debug("randomMillis:{}", randomMillis);
                 }
@@ -865,6 +865,7 @@ public class CloudGlobalTransactionMgr implements 
GlobalTransactionMgrIface {
             // not check return value, because the add will success
             AgentTaskQueue.addTask(task);
             batchTask.addTask(task);
+            LOG.info("send calculate delete bitmap task to be {}, txn_id {}", 
entry.getKey(), transactionId);
         }
         AgentTaskExecutor.submit(batchTask);
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to