diff --git a/apps/emqx_dashboard/src/emqx_dashboard_admin.erl b/apps/emqx_dashboard/src/emqx_dashboard_admin.erl index cbfb6c926..0e5616c64 100644 --- a/apps/emqx_dashboard/src/emqx_dashboard_admin.erl +++ b/apps/emqx_dashboard/src/emqx_dashboard_admin.erl @@ -65,7 +65,7 @@ mnesia(boot) -> {storage_properties, [{ets, [{read_concurrency, true}, {write_concurrency, true}]}]}]); mnesia(copy) -> - ok = ekka_mnesia:copy_table(mqtt_admin). + ok = ekka_mnesia:copy_table(mqtt_admin, disc_copies). %%-------------------------------------------------------------------- %% API diff --git a/apps/emqx_retainer/src/emqx_retainer.erl b/apps/emqx_retainer/src/emqx_retainer.erl index 9bf967b23..70f49a16c 100644 --- a/apps/emqx_retainer/src/emqx_retainer.erl +++ b/apps/emqx_retainer/src/emqx_retainer.erl @@ -138,7 +138,7 @@ init([Env]) -> {record_name, retained}, {attributes, record_info(fields, retained)}, {storage_properties, StoreProps}]), - ok = ekka_mnesia:copy_table(?TAB), + ok = ekka_mnesia:copy_table(?TAB, Copies), case mnesia:table_info(?TAB, storage_type) of Copies -> ok; _Other -> diff --git a/apps/emqx_rule_engine/src/emqx_rule_registry.erl b/apps/emqx_rule_engine/src/emqx_rule_registry.erl index 0a5358cc8..1ef5406cd 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_registry.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_registry.erl @@ -131,11 +131,11 @@ mnesia(boot) -> mnesia(copy) -> %% Copy rule table - ok = ekka_mnesia:copy_table(?RULE_TAB), + ok = ekka_mnesia:copy_table(?RULE_TAB, disc_copies), %% Copy rule action table ok = ekka_mnesia:copy_table(?ACTION_TAB), %% Copy resource table - ok = ekka_mnesia:copy_table(?RES_TAB), + ok = ekka_mnesia:copy_table(?RES_TAB, disc_copies), %% Copy resource type table ok = ekka_mnesia:copy_table(?RES_TYPE_TAB). diff --git a/src/emqx_alarm.erl b/src/emqx_alarm.erl index af2edf0fc..4a710acf7 100644 --- a/src/emqx_alarm.erl +++ b/src/emqx_alarm.erl @@ -112,8 +112,8 @@ mnesia(boot) -> {record_name, deactivated_alarm}, {attributes, record_info(fields, deactivated_alarm)}]); mnesia(copy) -> - ok = ekka_mnesia:copy_table(?ACTIVATED_ALARM), - ok = ekka_mnesia:copy_table(?DEACTIVATED_ALARM). + ok = ekka_mnesia:copy_table(?ACTIVATED_ALARM, disc_copies), + ok = ekka_mnesia:copy_table(?DEACTIVATED_ALARM, disc_copies). %%-------------------------------------------------------------------- %% API diff --git a/src/emqx_banned.erl b/src/emqx_banned.erl index 80f93be70..cbcd2e15f 100644 --- a/src/emqx_banned.erl +++ b/src/emqx_banned.erl @@ -62,7 +62,7 @@ mnesia(boot) -> {storage_properties, [{ets, [{read_concurrency, true}]}]}]); mnesia(copy) -> - ok = ekka_mnesia:copy_table(?BANNED_TAB). + ok = ekka_mnesia:copy_table(?BANNED_TAB, disc_copies). %% @doc Start the banned server. -spec(start_link() -> startlink_ret()).