Repository: incubator-slider Updated Branches: refs/heads/develop 31cdeaca9 -> bb873fdee
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/bb873fde Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/bb873fde Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/bb873fde Branch: refs/heads/develop Commit: bb873fdeee82d30d74e0d622ec1d0e1a46cd1aaf Parents: 31cdeac Author: Sumit Mohanty <[email protected]> Authored: Thu Nov 13 18:15:03 2014 -0800 Committer: Sumit Mohanty <[email protected]> Committed: Thu Nov 13 18:15:03 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/bb873fde/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 075a8a7..94fc32c 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 @@ -552,6 +552,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); }
