From 78c762479f7124c5208df95b1fdd010b162fba93 Mon Sep 17 00:00:00 2001 From: k32 <10274441+k32@users.noreply.github.com> Date: Mon, 7 Feb 2022 12:38:59 +0100 Subject: [PATCH] feat(router): Mark CM_SHARD and ROUTE_SHARD as dirty --- apps/emqx/src/emqx_cm_registry.erl | 1 + apps/emqx/src/emqx_router.erl | 1 + 2 files changed, 2 insertions(+) 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},