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 f51454ad269c51..4e1117ec93db83 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 @@ -782,8 +782,8 @@ private void getDeleteBitmapUpdateLock(Map> tableToParttions, lo 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); } @@ -855,6 +855,7 @@ private void sendCalcDeleteBitmaptask(long dbId, long transactionId, // 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);