This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/seatunnel-web.git


The following commit(s) were added to refs/heads/main by this push:
     new 72bb3f28b [Feature] Add creation and update timestamps to monitor task 
metrics (#301)
72bb3f28b is described below

commit 72bb3f28b2e52ca747560c705eea64b2bc550be5
Author: Jast <[email protected]>
AuthorDate: Fri Jul 18 11:59:38 2025 +0800

    [Feature] Add creation and update timestamps to monitor task metrics (#301)
---
 .../java/org/apache/seatunnel/app/scheduler/MonitorTaskScheduler.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/scheduler/MonitorTaskScheduler.java
 
b/seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/scheduler/MonitorTaskScheduler.java
index de30281f6..54aa156cc 100644
--- 
a/seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/scheduler/MonitorTaskScheduler.java
+++ 
b/seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/scheduler/MonitorTaskScheduler.java
@@ -35,6 +35,7 @@ import lombok.extern.slf4j.Slf4j;
 import javax.annotation.PreDestroy;
 import javax.annotation.Resource;
 
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -182,6 +183,8 @@ public class MonitorTaskScheduler {
                 .writeQps(metrics.getWriteQps())
                 .recordDelay(metrics.getRecordDelay())
                 .status(metrics.getStatus())
+                .createTime(LocalDateTime.now())
+                .updateTime(LocalDateTime.now())
                 .createUserId(-1)
                 .updateUserId(-1)
                 .build();

Reply via email to