From ddccfb62dcb214d437e97d87016244cefa3589bf Mon Sep 17 00:00:00 2001
From: Rui Fan <1996fanrui@gmail.com>
Date: Wed, 22 May 2024 15:43:47 +0800
Subject: [PATCH] [hotfix][rest] Add getter methods for SubtasksTimesInfo to
 get all values easily

---
 .../rest/messages/SubtasksTimesInfo.java      | 46 +++++++++++++++++++
 1 file changed, 46 insertions(+)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtasksTimesInfo.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtasksTimesInfo.java
index 67cf50778e8cb..39c067b270236 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtasksTimesInfo.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtasksTimesInfo.java
@@ -22,6 +22,7 @@
 import org.apache.flink.runtime.rest.handler.job.SubtasksTimesHandler;
 
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonCreator;
+import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonIgnore;
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonProperty;
 
 import java.util.List;
@@ -62,6 +63,26 @@ public SubtasksTimesInfo(
         this.subtasks = checkNotNull(subtasks);
     }
 
+    @JsonIgnore
+    public String getId() {
+        return id;
+    }
+
+    @JsonIgnore
+    public String getName() {
+        return name;
+    }
+
+    @JsonIgnore
+    public long getNow() {
+        return now;
+    }
+
+    @JsonIgnore
+    public List<SubtaskTimeInfo> getSubtasks() {
+        return subtasks;
+    }
+
     @Override
     public boolean equals(Object o) {
         if (this == o) {
@@ -125,6 +146,31 @@ public SubtaskTimeInfo(
             this.timestamps = checkNotNull(timestamps);
         }
 
+        @JsonIgnore
+        public int getSubtask() {
+            return subtask;
+        }
+
+        @JsonIgnore
+        public String getHost() {
+            return host;
+        }
+
+        @JsonIgnore
+        public String getEndpoint() {
+            return endpoint;
+        }
+
+        @JsonIgnore
+        public long getDuration() {
+            return duration;
+        }
+
+        @JsonIgnore
+        public Map<ExecutionState, Long> getTimestamps() {
+            return timestamps;
+        }
+
         @Override
         public boolean equals(Object o) {
             if (this == o) {