SLIDER-555. Default ZK node is not getting deleted when you destroy an application
Project: http://git-wip-us.apache.org/repos/asf/incubator-slider/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-slider/commit/2c6cc497 Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/2c6cc497 Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/2c6cc497 Branch: refs/heads/master Commit: 2c6cc4973edba44c5aaeea93653742e519c7188c Parents: c7186e1 Author: Sumit Mohanty <[email protected]> Authored: Thu Nov 13 18:15:03 2014 -0800 Committer: Sumit Mohanty <[email protected]> Committed: Thu Nov 13 18:24:48 2014 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/slider/client/SliderClient.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/2c6cc497/slider-core/src/main/java/org/apache/slider/client/SliderClient.java ---------------------------------------------------------------------- diff --git a/slider-core/src/main/java/org/apache/slider/client/SliderClient.java b/slider-core/src/main/java/org/apache/slider/client/SliderClient.java index 164e2fe..ee5be65 100644 --- a/slider-core/src/main/java/org/apache/slider/client/SliderClient.java +++ b/slider-core/src/main/java/org/apache/slider/client/SliderClient.java @@ -546,6 +546,11 @@ public class SliderClient extends AbstractSliderLaunchedService implements RunSe if (!deleted) { log.warn("Filesystem returned false from delete() operation"); } + + if(!deleteZookeeperNode(clustername)) { + log.warn("Unable to perform node cleanup in Zookeeper."); + } + if (fs.exists(clusterDirectory)) { log.warn("Failed to delete {}", clusterDirectory); }
