[GitHub] [flink] wanglijie95 commented on a diff in pull request #20056: [FLINK-28142][runtime] Enrich TaskManagerLocation and TaskExecutorRegistration with node information

[GitBox]

wanglijie95 commented on code in PR #20056:
URL: https://github.com/apache/flink/pull/20056#discussion_r909316312


##########
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/TaskExecutorRegistration.java:
##########
@@ -55,6 +56,10 @@ public class TaskExecutorRegistration implements 
Serializable {
     /** The task executor total resource profile. */
     private final ResourceProfile totalResourceProfile;
 
+    /** ID of the node where the TaskManager is located. */
+    private final String nodeId;

Review Comment:
   I have extracted it as a separate commit。



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org