From 05e47254e2a56d392f39a7330c19cc4b69f1f67f Mon Sep 17 00:00:00 2001
From: ieQu1 <99872536+ieQu1@users.noreply.github.com>
Date: Tue, 28 Nov 2023 12:57:03 +0100
Subject: [PATCH] fix(ds): Fixes related to the shards table

---
 .../src/emqx_ds_replication_layer_meta.erl                  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/apps/emqx_durable_storage/src/emqx_ds_replication_layer_meta.erl b/apps/emqx_durable_storage/src/emqx_ds_replication_layer_meta.erl
index 077df28d0..5c451206d 100644
--- a/apps/emqx_durable_storage/src/emqx_ds_replication_layer_meta.erl
+++ b/apps/emqx_durable_storage/src/emqx_ds_replication_layer_meta.erl
@@ -192,9 +192,9 @@ sites() ->
     {ok, node()} | {error, no_leader_for_shard}.
 shard_leader(DB, Shard) ->
     case mnesia:dirty_read(?SHARD_TAB, {DB, Shard}) of
-        [#?SHARD_TAB{leader = Leader}] ->
+        [#?SHARD_TAB{leader = Leader}] when Leader =/= undefined ->
             {ok, Leader};
-        [] ->
+        _ ->
             {error, no_leader_for_shard}
     end.
 
@@ -314,7 +314,7 @@ ensure_tables() ->
         {rlog_shard, ?SHARD},
         {majority, Majority},
         {type, ordered_set},
-        {storage, ram_copies},
+        {storage, disc_copies},
         {record_name, ?SHARD_TAB},
         {attributes, record_info(fields, ?SHARD_TAB)}
     ]),