This is an automated email from the ASF dual-hosted git repository.
zhangchen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new ef519c7ec64 [improve](cloud-mow) make the waiting time on
getDeleteBitmapUpdateLock more reasonable (#40341)
ef519c7ec64 is described below
commit ef519c7ec64658716e859df5dc8ed49a1880d5b5
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 7349efb3fca..9890eaa0b3a 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
@@ -794,8 +794,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);
}
@@ -867,6 +867,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]
