You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@slider.apache.org by sm...@apache.org on 2014/11/14 03:15:10 UTC
incubator-slider git commit: SLIDER-555. Default ZK node is not
getting deleted when you destroy an application
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 <sm...@hortonworks.com>
Authored: Thu Nov 13 18:15:03 2014 -0800
Committer: Sumit Mohanty <sm...@hortonworks.com>
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);
}