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

[fix](stats) Update analyze task execute time (#21026)

Browse Source 
Before this PR last_execute_time of pending analyze jobs would be 1970-01-01, you can reproduce it by run show analyze
This commit is contained in:
AKIRA
2023-06-25 16:52:33 +09:00
committed by GitHub
parent cf66280e60
commit 771b0cbb4c
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java
View File

@ -412,6 +412,7 @@ public class AnalysisManager extends Daemon implements Writable {
taskInfoBuilder.setSamplingPartition(isSamplingPartition);
taskInfoBuilder.setJobType(JobType.MANUAL);
taskInfoBuilder.setState(AnalysisState.PENDING);
taskInfoBuilder.setLastExecTimeInMs(System.currentTimeMillis());
taskInfoBuilder.setAnalysisType(analysisType);
taskInfoBuilder.setAnalysisMode(analysisMode);
taskInfoBuilder.setAnalysisMethod(analysisMethod);
@ -450,6 +451,7 @@ public class AnalysisManager extends Daemon implements Writable {
taskInfoBuilder.setTblName(jobInfo.tblName);
taskInfoBuilder.setJobType(JobType.SYSTEM);
taskInfoBuilder.setState(AnalysisState.PENDING);
taskInfoBuilder.setLastExecTimeInMs(System.currentTimeMillis());
taskInfoBuilder.setAnalysisType(jobInfo.analysisType);
taskInfoBuilder.setAnalysisMode(jobInfo.analysisMode);
taskInfoBuilder.setAnalysisMethod(jobInfo.analysisMethod);

2
fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisTaskWrapper.java
View File

@ -65,7 +65,7 @@ public class AnalysisTaskWrapper extends FutureTask<Void> {
LOG.warn("Failed to execute task", except);
Env.getCurrentEnv().getAnalysisManager()
.updateTaskStatus(task.info,
AnalysisState.FAILED, except.getMessage(), -1);
AnalysisState.FAILED, except.getMessage(), System.currentTimeMillis());
} else {
Env.getCurrentEnv().getAnalysisManager()
.updateTaskStatus(task.info,