[GitHub] zentol closed pull request #7378: [FLINK-11232][Webfrontend] Fix empty Start Time of sub-task on web da…

[GitBox <gi...@apache.org>]

zentol closed pull request #7378: [FLINK-11232][Webfrontend] Fix empty Start Time of sub-task on web da…
URL: https://github.com/apache/flink/pull/7378
 
 
   

This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:

As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexDetailsInfo.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexDetailsInfo.java
index df007f45c07..3ad1e411d29 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexDetailsInfo.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexDetailsInfo.java
@@ -110,7 +110,8 @@ public int hashCode() {
 		public static final String FIELD_NAME_STATUS = "status";
 		public static final String FIELD_NAME_ATTEMPT = "attempt";
 		public static final String FIELD_NAME_HOST = "host";
-		public static final String FIELD_NAME_START_TIME = "start_time";
+		public static final String FIELD_NAME_START_TIME = "start-time";
+		public static final String FIELD_NAME_COMPATIBLE_START_TIME = "start_time";
 		public static final String FIELD_NAME_END_TIME = "end-time";
 		public static final String FIELD_NAME_DURATION = "duration";
 		public static final String FIELD_NAME_METRICS = "metrics";
@@ -130,6 +131,9 @@ public int hashCode() {
 		@JsonProperty(FIELD_NAME_START_TIME)
 		private final long startTime;
 
+		@JsonProperty(FIELD_NAME_COMPATIBLE_START_TIME)
+		private final long startTimeCompatible;
+
 		@JsonProperty(FIELD_NAME_END_TIME)
 		private final long endTime;
 
@@ -154,6 +158,7 @@ public VertexTaskDetail(
 			this.attempt = attempt;
 			this.host = checkNotNull(host);
 			this.startTime = startTime;
+			this.startTimeCompatible = startTime;
 			this.endTime = endTime;
 			this.duration = duration;
 			this.metrics = checkNotNull(metrics);
@@ -175,6 +180,7 @@ public boolean equals(Object o) {
 				attempt == that.attempt &&
 				Objects.equals(host, that.host) &&
 				startTime == that.startTime &&
+				startTimeCompatible == that.startTimeCompatible &&
 				endTime == that.endTime &&
 				duration == that.duration &&
 				Objects.equals(metrics, that.metrics);
@@ -182,7 +188,7 @@ public boolean equals(Object o) {
 
 		@Override
 		public int hashCode() {
-			return Objects.hash(subtask, status, attempt, host, startTime, endTime, duration, metrics);
+			return Objects.hash(subtask, status, attempt, host, startTime, startTimeCompatible, endTime, duration, metrics);
 		}
 	}
 }


 

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services