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 5b1c3bb3b7d..09daf424d15 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 R execOnActiveRM(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