diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-api/src/main/java/org/apache/hadoop/yarn/service/client/ApiServiceClient.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-api/src/main/java/org/apache/hadoop/yarn/service/client/ApiServiceClient.java index a6d15026da0..008f49792de 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-api/src/main/java/org/apache/hadoop/yarn/service/client/ApiServiceClient.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-api/src/main/java/org/apache/hadoop/yarn/service/client/ApiServiceClient.java @@ -226,11 +226,10 @@ private Builder getApiClient() throws IOException { private Builder getApiClient(String requestPath) throws IOException { Client client = Client.create(getClientConfig()); - Configuration conf = getConfig(); client.setChunkedEncodingSize(null); Builder builder = client .resource(requestPath).type(MediaType.APPLICATION_JSON); - if (conf.get("hadoop.http.authentication.type").equals("kerberos")) { + if (UserGroupInformation.isSecurityEnabled()) { try { URI url = new URI(requestPath); String challenge = YarnClientUtils.generateToken(url.getHost());