You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@brooklyn.apache.org by gr...@apache.org on 2015/03/26 19:28:18 UTC
[5/6] incubator-brooklyn git commit: Mark removed node as down
Mark removed node as down
Project: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/commit/524a74e1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/tree/524a74e1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/diff/524a74e1
Branch: refs/heads/master
Commit: 524a74e1602db17e721cb4f314f150e5e0749714
Parents: dd3a7e4
Author: Andrew Kennedy <gr...@apache.org>
Authored: Thu Mar 26 15:09:09 2015 +0000
Committer: Andrew Kennedy <gr...@apache.org>
Committed: Thu Mar 26 15:09:09 2015 +0000
----------------------------------------------------------------------
.../src/main/java/brooklyn/entity/nosql/riak/RiakNodeSshDriver.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/524a74e1/software/nosql/src/main/java/brooklyn/entity/nosql/riak/RiakNodeSshDriver.java
----------------------------------------------------------------------
diff --git a/software/nosql/src/main/java/brooklyn/entity/nosql/riak/RiakNodeSshDriver.java b/software/nosql/src/main/java/brooklyn/entity/nosql/riak/RiakNodeSshDriver.java
index 034b31e..7a4d952 100644
--- a/software/nosql/src/main/java/brooklyn/entity/nosql/riak/RiakNodeSshDriver.java
+++ b/software/nosql/src/main/java/brooklyn/entity/nosql/riak/RiakNodeSshDriver.java
@@ -439,6 +439,7 @@ public class RiakNodeSshDriver extends AbstractSoftwareProcessSshDriver implemen
public void removeNode(String nodeName) {
ScriptHelper removeNodeScript = newScript("removeNode")
.body.append(sudo(format("%s cluster force-remove %s", getRiakAdminCmd(), nodeName)))
+ .body.append(sudo(format("%s down %s", getRiakAdminCmd(), nodeName)))
.body.append(sudo(format("%s cluster plan", getRiakAdminCmd())))
.body.append(sudo(format("%s cluster commit", getRiakAdminCmd())))
.failOnNonZeroResultCode();