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 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 getTimestamps() { + return timestamps; + } + @Override public boolean equals(Object o) { if (this == o) {