From a49010d1d1c699e451b2fa5158b32baa8fd4641e Mon Sep 17 00:00:00 2001 From: Yuriy Malygin Date: Wed, 21 Mar 2018 16:23:35 +0300 Subject: [PATCH] Fix possible NPE when start Application Master Fix possible NPE when yarn.resourcemanager.webapp.address or yarn.resourcemanager.webapp.https.address is not set in yarn-site.xml (incomplete configuration of HA) --- .../yarn/server/webproxy/amfilter/AmFilterInitializer.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-web-proxy/src/main/java/org/apache/hadoop/yarn/server/webproxy/amfilter/AmFilterInitializer.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-web-proxy/src/main/java/org/apache/hadoop/yarn/server/webproxy/amfilter/AmFilterInitializer.java index 27742e41a29e2..100cc27e043e1 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-web-proxy/src/main/java/org/apache/hadoop/yarn/server/webproxy/amfilter/AmFilterInitializer.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-web-proxy/src/main/java/org/apache/hadoop/yarn/server/webproxy/amfilter/AmFilterInitializer.java @@ -68,7 +68,9 @@ public void initFilter(FilterContainer container, Configuration conf) { List urls = new ArrayList<>(); for (String rmId : rmIds) { String url = getUrlByRmId(yarnConf, rmId); - urls.add(url); + if (url != null) { + urls.add(url); + } } if (!urls.isEmpty()) { params.put(RM_HA_URLS, StringUtils.join(",", urls));