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 <[email protected]> Authored: Thu Mar 26 15:09:09 2015 +0000 Committer: Andrew Kennedy <[email protected]> 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();
