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();