diff --git a/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java b/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java index c4443e5733..1b8f2e7e0d 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java @@ -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); diff --git a/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisTaskWrapper.java b/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisTaskWrapper.java index 864c9100d8..9a0d6ec2fc 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisTaskWrapper.java +++ b/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisTaskWrapper.java @@ -65,7 +65,7 @@ public class AnalysisTaskWrapper extends FutureTask { 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,