From 79c2fa631e6e7cd4e3ff8cdcb3f9c9b3b1dbcbcf Mon Sep 17 00:00:00 2001
From: Feng Lee <feng@emqtt.io>
Date: Tue, 13 Jun 2017 10:35:22 +0800
Subject: [PATCH] Fix the issue that we cannot remove a down node from the
 cluster

---
 src/emqttd_cluster.erl | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/emqttd_cluster.erl b/src/emqttd_cluster.erl
index ab40875aa..28b2d1723 100644
--- a/src/emqttd_cluster.erl
+++ b/src/emqttd_cluster.erl
@@ -50,7 +50,7 @@ prepare() ->
 %% @doc Is node in cluster?
 -spec(is_clustered(node()) -> boolean()).
 is_clustered(Node) ->
-    lists:member(Node, emqttd_mnesia:running_nodes()).
+    lists:member(Node, emqttd_mnesia:cluster_nodes(all)).
 
 %% @doc Reboot after join or leave cluster.
 -spec(reboot() -> ok).