SLIDER-453 AM queue processing goes live before init complete - SLIDER-149 extension
Project: http://git-wip-us.apache.org/repos/asf/incubator-slider/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-slider/commit/8b2d4d5a Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/8b2d4d5a Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/8b2d4d5a Branch: refs/heads/develop Commit: 8b2d4d5a17e0f8f49a1eb04c4a5fe1e653f532aa Parents: 77ca3c2 Author: Steve Loughran <ste...@apache.org> Authored: Tue Sep 23 21:59:30 2014 +0100 Committer: Steve Loughran <ste...@apache.org> Committed: Tue Sep 23 21:59:30 2014 +0100 ---------------------------------------------------------------------- .../org/apache/slider/server/appmaster/SliderAppMaster.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/8b2d4d5a/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java ---------------------------------------------------------------------- diff --git a/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java b/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java index 2fa8342..754013a 100644 --- a/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java +++ b/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java @@ -1047,12 +1047,15 @@ public class SliderAppMaster extends AbstractSliderLaunchedService * Handler for {@link UnregisterComponentInstance} * * unregister a component. At the time this message is received, - * the component may already been deleted from/never added to - * the app state + * the component may not have been registered * @param id the component */ public void unregisterComponent(ContainerId id) { log.info("Unregistering component {}", id); + if (yarnRegistryOperations== null) { + log.warn("Processing unregister component event before initialization " + + "completed; init flag =" + initCompleted); + } String cid = RegistryPathUtils.encodeYarnID(id.toString()); try { yarnRegistryOperations.rmComponent(cid);
