diff --git a/apps/emqx/src/emqx_cm_registry.erl b/apps/emqx/src/emqx_cm_registry.erl index 4d70c4000..89d17ae9e 100644 --- a/apps/emqx/src/emqx_cm_registry.erl +++ b/apps/emqx/src/emqx_cm_registry.erl @@ -100,6 +100,7 @@ record(ClientId, ChanPid) -> %%-------------------------------------------------------------------- init([]) -> + mria_config:set_dirty_shard(?CM_SHARD, true), ok = mria:create_table(?TAB, [ {type, bag}, {rlog_shard, ?CM_SHARD}, diff --git a/apps/emqx/src/emqx_router.erl b/apps/emqx/src/emqx_router.erl index 9436de275..45440d198 100644 --- a/apps/emqx/src/emqx_router.erl +++ b/apps/emqx/src/emqx_router.erl @@ -73,6 +73,7 @@ %%-------------------------------------------------------------------- mnesia(boot) -> + mria_config:set_dirty_shard(?ROUTE_SHARD, true), ok = mria:create_table(?ROUTE_TAB, [ {type, bag}, {rlog_shard, ?ROUTE_SHARD},