database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Improve](txn) Add some fuzzy test stub in txn (#26712)

Browse Source
This commit is contained in:
deardeng
2023-11-16 11:50:06 +08:00
committed by GitHub
parent 624d372dcd
commit 7e82e7651a
3 changed files with 92 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
fe/fe-core/src/main/java/org/apache/doris/alter/AlterJobV2.java
View File

@ -26,6 +26,7 @@ import org.apache.doris.common.Config;
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.persist.gson.GsonUtils;
import com.google.gson.annotations.SerializedName;
@ -164,6 +165,19 @@ public abstract class AlterJobV2 implements Writable {
this.finishedTimeMs = finishedTimeMs;
}
// /api/debug_point/add/{name}?value=100
private void stateWait(final String name) {
long waitTimeMs = DebugPointUtil.getDebugParamOrDefault(name, 0);
if (waitTimeMs > 0) {
try {
LOG.info("debug point {} wait {} ms", name, waitTimeMs);
Thread.sleep(waitTimeMs);
} catch (InterruptedException e) {
LOG.warn(name, e);
}
}
}
/**
* The keyword 'synchronized' only protects 2 methods:
* run() and cancel()
@ -180,15 +194,24 @@ public abstract class AlterJobV2 implements Writable {
return;
}
// /api/debug_point/add/FE.STOP_ALTER_JOB_RUN
if (DebugPointUtil.isEnable("FE.STOP_ALTER_JOB_RUN")) {
LOG.info("debug point FE.STOP_ALTER_JOB_RUN, schema change schedule stopped");
return;
}
try {
switch (jobState) {
case PENDING:
stateWait("FE.ALTER_JOB_V2_PENDING");
runPendingJob();
break;
case WAITING_TXN:
stateWait("FE.ALTER_JOB_V2_WAITING_TXN");
runWaitingTxnJob();
break;
case RUNNING:
stateWait("FE.ALTER_JOB_V2_RUNNING");
runRunningJob();
break;
default: