[BugFix] reset the start time before execution (backport #55433) (#55468

) Co-authored-by: Murphy <[email protected]>
StarRocks · Jan 27, 2025 · 24f290e · 24f290e
1 parent b049258
commit 24f290e
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 0 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/statistic/AnalyzeStatus.java b/fe/fe-core/src/main/java/com/starrocks/statistic/AnalyzeStatus.java
@@ -56,6 +56,8 @@ public interface AnalyzeStatus {
 
     LocalDateTime getEndTime();
 
+    void setStartTime(LocalDateTime endTime);
+
     void setEndTime(LocalDateTime endTime);
 
     void setStatus(StatsConstants.ScheduleStatus status);

diff --git a/fe/fe-core/src/main/java/com/starrocks/statistic/ExternalAnalyzeStatus.java b/fe/fe-core/src/main/java/com/starrocks/statistic/ExternalAnalyzeStatus.java
@@ -152,6 +152,11 @@ public LocalDateTime getEndTime() {
         return endTime;
     }
 
+    @Override
+    public void setStartTime(LocalDateTime startTime) {
+        this.startTime = startTime;
+    }
+
     @Override
     public void setEndTime(LocalDateTime endTime) {
         this.endTime = endTime;

diff --git a/fe/fe-core/src/main/java/com/starrocks/statistic/NativeAnalyzeStatus.java b/fe/fe-core/src/main/java/com/starrocks/statistic/NativeAnalyzeStatus.java
@@ -164,6 +164,11 @@ public LocalDateTime getEndTime() {
         return endTime;
     }
 
+    @Override
+    public void setStartTime(LocalDateTime startTime) {
+        this.startTime = startTime;
+    }
+
     @Override
     public void setEndTime(LocalDateTime endTime) {
         this.endTime = endTime;

diff --git a/fe/fe-core/src/main/java/com/starrocks/statistic/StatisticUtils.java b/fe/fe-core/src/main/java/com/starrocks/statistic/StatisticUtils.java
@@ -194,6 +194,7 @@ public static void triggerCollectionOnFirstLoad(
         try {
             future = GlobalStateMgr.getCurrentAnalyzeMgr().getAnalyzeTaskThreadPool()
                     .submit(() -> {
+                        analyzeStatus.setStartTime(LocalDateTime.now());
                         StatisticExecutor statisticExecutor = new StatisticExecutor();
                         ConnectContext statsConnectCtx = StatisticUtils.buildConnectContext();
                         statsConnectCtx.setThreadLocalInfo();