diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/webapp/log/AggregatedLogsBlock.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/webapp/log/AggregatedLogsBlock.java index 2b83e69..4a75e3f 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/webapp/log/AggregatedLogsBlock.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/webapp/log/AggregatedLogsBlock.java @@ -79,8 +79,17 @@ protected void render(Block html) { if (!conf.getBoolean(YarnConfiguration.LOG_AGGREGATION_ENABLED, YarnConfiguration.DEFAULT_LOG_AGGREGATION_ENABLED)) { + String nmHostAndPort = conf.get(YarnConfiguration.NM_WEBAPP_ADDRESS, YarnConfiguration.DEFAULT_NM_WEBAPP_ADDRESS); + String[] nmHostAndPortSplit = nmHostAndPort.split(":"); + String noAggPort = nmHostAndPortSplit[1]; + String[] nodeIdSplit = nodeId.toString().split(":"); + String noAggHost = nodeIdSplit[0]; + String finalHostAndPort = noAggHost + ":" + noAggPort; html.h1() - ._("Aggregation is not enabled. Try the nodemanager at " + nodeId) + ._("Aggregation is not enabled. Try the nodemanager at ") + ._(); + html.h1() + .a(".nmlink", url("http://" + finalHostAndPort),finalHostAndPort) ._(); return; } @@ -321,4 +330,4 @@ private LogLimits verifyAndGetLogLimits(Block html) { limits.end = end; return limits; } -} \ No newline at end of file +}