commit | 72bb3f28b2e52ca747560c705eea64b2bc550be5 | [log] [tgz] |
---|---|---|
author | Jast <shenghang@apache.org> | Fri Jul 18 11:59:38 2025 +0800 |
committer | GitHub <noreply@github.com> | Fri Jul 18 11:59:38 2025 +0800 |
tree | 16c82e8b1f4b94924a351b29ae3cb284fd742715 | |
parent | 2c8736f06c20e8dd630dd66133b24b86c173705c [diff] |
[Feature] Add creation and update timestamps to monitor task metrics (#301)
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 de30281..54aa156 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 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 @@ .writeQps(metrics.getWriteQps()) .recordDelay(metrics.getRecordDelay()) .status(metrics.getStatus()) + .createTime(LocalDateTime.now()) + .updateTime(LocalDateTime.now()) .createUserId(-1) .updateUserId(-1) .build();