From ae6ac809f026ebe9d0c0bb2f26fb483514c5a621 Mon Sep 17 00:00:00 2001 From: Prabhu Joseph Date: Fri, 7 Jun 2019 18:07:24 +0530 Subject: [PATCH] YARN-9581. Fix LogsCli ignores multiple RMs. --- .../java/org/apache/hadoop/yarn/webapp/util/WebAppUtils.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/webapp/util/WebAppUtils.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/webapp/util/WebAppUtils.java index 5b1c3bb..09daf42 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/webapp/util/WebAppUtils.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/webapp/util/WebAppUtils.java @@ -102,8 +102,16 @@ public static void setNMWebAppHostNameAndPort(Configuration conf, return func.apply(rm1Address, arg); } catch (Exception e) { if (HAUtil.isHAEnabled(conf)) { - String rm2Address = getRMWebAppURLWithScheme(conf, 1); - return func.apply(rm2Address, arg); + int rms = HAUtil.getRMHAIds(conf).size(); + for (int i=1; i