From ef384b55749b719d51ed0c49bd810327db586b88 Mon Sep 17 00:00:00 2001 From: Echo009 Date: Fri, 26 Feb 2021 11:32:03 +0800 Subject: [PATCH] feat: add job parameters info into fetching job instance detail api --- .../powerjob/common/model/InstanceDetail.java | 4 ++ .../common/response/InstanceInfoDTO.java | 52 ++++++++++++++----- .../server/web/response/InstanceDetailVO.java | 52 ++++++++++++++----- 3 files changed, 84 insertions(+), 24 deletions(-) diff --git a/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/model/InstanceDetail.java b/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/model/InstanceDetail.java index 55fd57df..16a14d27 100644 --- a/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/model/InstanceDetail.java +++ b/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/model/InstanceDetail.java @@ -40,6 +40,10 @@ public class InstanceDetail implements OmsSerializable { * Task tracker address. */ private String taskTrackerAddress; + /** + * 任务参数 + */ + private String jobParams; /** * Param string that is passed to an instance when it is initialized. */ diff --git a/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/response/InstanceInfoDTO.java b/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/response/InstanceInfoDTO.java index 4d52b223..e639e359 100644 --- a/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/response/InstanceInfoDTO.java +++ b/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/response/InstanceInfoDTO.java @@ -14,34 +14,62 @@ import java.util.Date; @Data public class InstanceInfoDTO { - // 任务ID + /** + * 任务ID + */ private Long jobId; - // 任务所属应用的ID,冗余提高查询效率 + /** + * 任务所属应用的ID,冗余提高查询效率 + */ private Long appId; - // 任务实例ID + /** + * 任务实例ID + */ private Long instanceId; - // 工作流实例ID + /** + * 工作流实例ID + */ private Long wfInstanceId; - // 任务实例参数 + /** + * 任务参数 + */ + private String jobParams; + /** + * 任务实例参数 + */ private String instanceParams; /** * 任务状态 {@link InstanceStatus} */ private int status; - // 该任务实例的类型,普通/工作流(InstanceType) + /** + * 该任务实例的类型,普通/工作流(InstanceType) + */ private Integer type; - // 执行结果 + /** + * 执行结果 + */ private String result; - // 预计触发时间 + /** + * 预计触发时间 + */ private Long expectedTriggerTime; - // 实际触发时间 + /** + * 实际触发时间 + */ private Long actualTriggerTime; - // 结束时间 + /** + * 结束时间 + */ private Long finishedTime; - // TaskTracker地址 + /** + * TaskTracker地址 + */ private String taskTrackerAddress; - // 总共执行的次数(用于重试判断) + /** + * 总共执行的次数(用于重试判断) + */ private Long runningTimes; private Date gmtCreate; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/response/InstanceDetailVO.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/response/InstanceDetailVO.java index f1081cba..18ec3d4c 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/response/InstanceDetailVO.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/response/InstanceDetailVO.java @@ -22,30 +22,56 @@ import java.util.List; @NoArgsConstructor public class InstanceDetailVO { - // 任务预计执行时间 + /** + * 任务预计执行时间 + */ private String expectedTriggerTime; - // 任务整体开始时间 + /** + * 任务整体开始时间 + */ private String actualTriggerTime; - // 任务整体结束时间(可能不存在) + /** + * 任务整体结束时间(可能不存在) + */ private String finishedTime; - // 任务状态 + /** + * 任务状态 + */ private Integer status; - // 任务执行结果(可能不存在) + /** + * 任务执行结果(可能不存在) + */ private String result; - // TaskTracker地址 + /** + * TaskTracker地址 + */ private String taskTrackerAddress; - // 启动参数 + /** + * 任务参数 + */ + private String jobParams; + /** + * 启动参数 + */ private String instanceParams; - // MR或BD任务专用 + /** + * MR或BD任务专用 + */ private InstanceDetailVO.TaskDetail taskDetail; - // 秒级任务专用 + /** + * 秒级任务专用 + */ private List subInstanceDetails; - // 重试次数 + /** + * 重试次数 + */ private Long runningTimes; - // 秒级任务的 extra -> List + /** + * 秒级任务的 extra -> List + */ @Data @NoArgsConstructor public static class SubInstanceDetail implements OmsSerializable { @@ -56,7 +82,9 @@ public class InstanceDetailVO { private int status; } - // MapReduce 和 Broadcast 任务的 extra -> + /** + * MapReduce 和 Broadcast 任务的 extra -> + */ @Data @NoArgsConstructor public static class TaskDetail implements OmsSerializable {