YARN-7954. Set component status to STOPPED when YARN service is stopped. Contributed by Gour Saha
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/31009034 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/31009034 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/31009034 Branch: refs/heads/HDFS-7240 Commit: 31009034bd16085b4634bfd861d32cdb9abab92a Parents: f20e10b Author: Billie Rinaldi <bil...@apache.org> Authored: Wed Feb 28 11:57:24 2018 -0800 Committer: Billie Rinaldi <bil...@apache.org> Committed: Wed Feb 28 11:57:24 2018 -0800 ---------------------------------------------------------------------- .../org/apache/hadoop/yarn/service/ServiceScheduler.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/31009034/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/ServiceScheduler.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/ServiceScheduler.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/ServiceScheduler.java index dfe9808..9bf567a 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/ServiceScheduler.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/ServiceScheduler.java @@ -96,6 +96,7 @@ import java.util.concurrent.TimeUnit; import static org.apache.hadoop.fs.FileSystem.FS_DEFAULT_NAME_KEY; import static org.apache.hadoop.registry.client.api.RegistryConstants.*; +import static org.apache.hadoop.yarn.api.records.ContainerExitStatus.KILLED_AFTER_APP_COMPLETION; import static org.apache.hadoop.yarn.service.api.ServiceApiConstants.*; import static org.apache.hadoop.yarn.service.component.ComponentEventType.*; @@ -253,6 +254,13 @@ public class ServiceScheduler extends CompositeService { public void serviceStop() throws Exception { LOG.info("Stopping service scheduler"); + // Mark component-instances/containers as STOPPED + if (YarnConfiguration.timelineServiceV2Enabled(getConfig())) { + for (ContainerId containerId : getLiveInstances().keySet()) { + serviceTimelinePublisher.componentInstanceFinished(containerId, + KILLED_AFTER_APP_COMPLETION, diagnostics.toString()); + } + } if (executorService != null) { executorService.shutdownNow(); } --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
