From 26de4f0de789f58736d1dc383125cffb54debdd0 Mon Sep 17 00:00:00 2001 From: Li Lu Date: Thu, 28 Jul 2016 10:23:18 -0700 Subject: [PATCH] YARN-5440. Use AHSClient in YarnClient when TimelineServer is running. (Xuan Gong via gtcarrera9) --- .../yarn/client/api/impl/YarnClientImpl.java | 19 ++++++++++++------- 1 file changed, 12 insertions(+), 7 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/YarnClientImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/YarnClientImpl.java index ae8716eaa2..dee31c5885 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/YarnClientImpl.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/YarnClientImpl.java @@ -165,13 +165,6 @@ protected void serviceInit(Configuration conf) throws Exception { YarnConfiguration.DEFAULT_YARN_CLIENT_APPLICATION_CLIENT_PROTOCOL_POLL_INTERVAL_MS); } - if (conf.getBoolean(YarnConfiguration.APPLICATION_HISTORY_ENABLED, - YarnConfiguration.DEFAULT_APPLICATION_HISTORY_ENABLED)) { - historyServiceEnabled = true; - historyClient = AHSClient.createAHSClient(); - historyClient.init(conf); - } - if (conf.getBoolean(YarnConfiguration.TIMELINE_SERVICE_ENABLED, YarnConfiguration.DEFAULT_TIMELINE_SERVICE_ENABLED)) { timelineServiceEnabled = true; @@ -181,6 +174,18 @@ protected void serviceInit(Configuration conf) throws Exception { timelineService = TimelineUtils.buildTimelineTokenService(conf); } + // The AHSClientService is enabled by default when we start the + // TimelineServer which means we are able to get history information + // for applications/applicationAttempts/containers by using ahsClient + // when the TimelineServer is running. + if (timelineServiceEnabled || conf.getBoolean( + YarnConfiguration.APPLICATION_HISTORY_ENABLED, + YarnConfiguration.DEFAULT_APPLICATION_HISTORY_ENABLED)) { + historyServiceEnabled = true; + historyClient = AHSClient.createAHSClient(); + historyClient.init(conf); + } + timelineServiceBestEffort = conf.getBoolean( YarnConfiguration.TIMELINE_SERVICE_CLIENT_BEST_EFFORT, YarnConfiguration.DEFAULT_TIMELINE_SERVICE_CLIENT_BEST_EFFORT);