From 771b0cbb4c6a16d71fe2cbbf32f30ebe80c4992b Mon Sep 17 00:00:00 2001
From: AKIRA <33112463+Kikyou1997@users.noreply.github.com>
Date: Sun, 25 Jun 2023 16:52:33 +0900
Subject: [PATCH] [fix](stats) Update analyze task execute time (#21026)

Before this PR last_execute_time of pending analyze jobs would be 1970-01-01, you can reproduce it by run show analyze
---
 .../main/java/org/apache/doris/statistics/AnalysisManager.java  | 2 ++
 .../java/org/apache/doris/statistics/AnalysisTaskWrapper.java   | 2 +-
 2 files changed, 3 insertions(+), 1 deletion(-)

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<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,