This is an automated email from the ASF dual-hosted git repository.
gavinchou 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 b95e0b98072 [opt](feMeta) Add random sleep for logEdit to test same
corner case (#53386)
b95e0b98072 is described below
commit b95e0b98072f92b7c6c76a54ff296b12b8222bd6
Author: deardeng <[email protected]>
AuthorDate: Sat Jul 19 10:29:28 2025 +0800
[opt](feMeta) Add random sleep for logEdit to test same corner case (#53386)
---
.../java/org/apache/doris/persist/EditLog.java | 24 ++++++++++++++--------
1 file changed, 16 insertions(+), 8 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java
b/fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java
index 0cac53555dd..098f0c3b752 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/persist/EditLog.java
@@ -47,6 +47,7 @@ import org.apache.doris.common.FeConstants;
import org.apache.doris.common.MetaNotFoundException;
import org.apache.doris.common.io.Text;
import org.apache.doris.common.io.Writable;
+import org.apache.doris.common.util.DebugPointUtil;
import org.apache.doris.common.util.SmallFileMgr.SmallFile;
import org.apache.doris.cooldown.CooldownConfHandler;
import org.apache.doris.cooldown.CooldownConfList;
@@ -112,6 +113,7 @@ import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
+import java.util.Random;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
@@ -1560,6 +1562,20 @@ public class EditLog {
}
long start = System.currentTimeMillis();
+ if (DebugPointUtil.isEnable("EditLog.logEdit.randomSleep")) {
+ DebugPointUtil.DebugPoint debugPoint =
DebugPointUtil.getDebugPoint("EditLog.logEdit.randomSleep");
+ int upperLimit = debugPoint.param("upperLimit", 3000);
+ long timestamp = System.currentTimeMillis();
+ Random random = new Random(timestamp);
+ try {
+ int ms = Math.abs(random.nextInt()) % upperLimit;
+ Thread.sleep(ms);
+ LOG.info("logEdit in debug point op {} content {} sleep {} ms",
+ OperationType.getOpName(op), writable.toString(), ms);
+ } catch (InterruptedException e) {
+ LOG.warn("sleep exception op {} content {}",
OperationType.getOpName(op), writable.toString(), e);
+ }
+ }
long logId = -1;
if (Config.enable_batch_editlog && op != OperationType.OP_TIMESTAMP) {
logId = logEditWithQueue(op, writable);
@@ -1599,10 +1615,6 @@ public class EditLog {
return journal.getJournalNum();
}
- public synchronized long getTxId() {
- return txId;
- }
-
public void logSaveNextId(long nextId) {
logEdit(OperationType.OP_SAVE_NEXTID, new Text(Long.toString(nextId)));
}
@@ -2342,10 +2354,6 @@ public class EditLog {
logEdit(OperationType.OP_DELETE_ANALYSIS_JOB, log);
}
- public void logDeleteAnalysisTask(AnalyzeDeletionLog log) {
- logEdit(OperationType.OP_DELETE_ANALYSIS_TASK, log);
- }
-
public long logAlterDatabaseProperty(AlterDatabasePropertyInfo log) {
long logId = logEdit(OperationType.OP_ALTER_DATABASE_PROPERTY, log);
Env.getCurrentEnv().getBinlogManager().addAlterDatabaseProperty(log,
logId);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
