diff --git a/apps/emqttd/src/emqttd_ctl.erl b/apps/emqttd/src/emqttd_ctl.erl
index f99048114..dfa8936c7 100644
--- a/apps/emqttd/src/emqttd_ctl.erl
+++ b/apps/emqttd/src/emqttd_ctl.erl
@@ -68,7 +68,7 @@ cluster([SNode]) ->
 	pong ->
 		application:stop(emqttd),
         application:stop(esockd),
-        emqtt_mnesia:cluster(Node),
+        emqttd_mnesia:cluster(Node),
         application:start(esockd),
 		application:start(emqttd),
 		?PRINT("cluster with ~p successfully.~n", [Node]);
diff --git a/apps/emqttd/src/emqttd_mnesia.erl b/apps/emqttd/src/emqttd_mnesia.erl
index 8cb688936..f7e5d5bab 100644
--- a/apps/emqttd/src/emqttd_mnesia.erl
+++ b/apps/emqttd/src/emqttd_mnesia.erl
@@ -153,13 +153,13 @@ wait_for_tables() ->
 %% Simple cluster with another nodes.
 %%
 %% @end
-%%------------------------------------------------------------------------------
+%%--------------
 cluster(Node) ->
     %% stop mnesia 
     mnesia:stop(),
     ok = wait_for_mnesia(stop),
     %% delete mnesia
-    ok = mnesia:delete_schema(node()),
+    ok = mnesia:delete_schema([node()]),
     %% start mnesia
     ok = mnesia:start(),
     %% connect with extra_db_nodes