diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/webapp/WebApps.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/webapp/WebApps.java index 7f70d98..8b062ce 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/webapp/WebApps.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/webapp/WebApps.java @@ -222,11 +222,18 @@ public void setup() { .setACL(new AdminACLsManager(conf).getAdminAcl()) .setPathSpec(pathList.toArray(new String[0])); - boolean hasSpnegoConf = spnegoPrincipalKey != null - && spnegoKeytabKey != null; + boolean hasSpnegoConf = true; + if (spnegoPrincipalKey == null || conf.get(spnegoPrincipalKey, "").isEmpty()) { + LOG.warn("Principal for spnego filter is not set"); + hasSpnegoConf = false; + } + if (spnegoKeytabKey == null || conf.get(spnegoKeytabKey, "").isEmpty()) { + LOG.warn("Keytab for spnego filter is not set"); + hasSpnegoConf = false; + } if (hasSpnegoConf) { - builder.setUsernameConfKey(conf.get(spnegoPrincipalKey)) - .setKeytabConfKey(conf.get(spnegoKeytabKey)) + builder.setUsernameConfKey(spnegoPrincipalKey) + .setKeytabConfKey(spnegoKeytabKey) .setSecurityEnabled(UserGroupInformation.isSecurityEnabled()); } HttpServer server = builder.build();