diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/AppInfo.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/AppInfo.java index c5c02a8..0d31a02 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/AppInfo.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/dao/AppInfo.java @@ -82,6 +82,7 @@ protected long elapsedTime; protected String amContainerLogs; protected String amHostHttpAddress; + private String amRPCAddress; protected long allocatedMB; protected long allocatedVCores; protected int runningContainers; @@ -167,6 +168,7 @@ public AppInfo(ResourceManager rm, RMApp app, Boolean hasAccess, schemePrefix + masterContainer.getNodeHttpAddress(), masterContainer.getId().toString(), app.getUser()); this.amHostHttpAddress = masterContainer.getNodeHttpAddress(); + this.amRPCAddress = attempt.getHost() + ":" + attempt.getRpcPort(); } ApplicationResourceUsageReport resourceReport = attempt @@ -281,6 +283,10 @@ public String getAMHostHttpAddress() { return this.amHostHttpAddress; } + public String getAmRPCAddress() { + return amRPCAddress; + } + public boolean amContainerLogsExist() { return this.amContainerLogsExist; }