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/c4740190 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/c4740190 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/c4740190 Branch: refs/heads/YARN-7055 Commit: c47401903ce6788a79667c9a9009a970bc19f3c7 Parents: 2c6e454 Author: Billie Rinaldi <bil...@apache.org> Authored: Wed Feb 28 11:57:24 2018 -0800 Committer: Rohith Sharma K S <rohithsharm...@apache.org> Committed: Fri Mar 2 11:08:28 2018 +0530 ---------------------------------------------------------------------- .../org/apache/hadoop/yarn/service/ServiceScheduler.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/c4740190/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
