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