소스 검색

Merge pull request #11158 from lafirest/fix/wait_table_in_retainer

fix(emqx_retainer): wait for Mria tables
lafirest 2 년 전
부모
커밋
be1a4c89a5
2개의 변경된 파일2개의 추가작업 그리고 0개의 파일을 삭제
  1. 1 0
      apps/emqx_retainer/src/emqx_retainer_mnesia.erl
  2. 1 0
      changes/ce/fix-11158.en.md

+ 1 - 0
apps/emqx_retainer/src/emqx_retainer_mnesia.erl

@@ -127,6 +127,7 @@ create_table(Table, RecordName, Attributes, Type, StorageType) ->
         {storage_properties, StoreProps}
     ]),
     ok = mria_rlog:wait_for_shards([?RETAINER_SHARD], infinity),
+    ok = mria:wait_for_tables([Table]),
     case mnesia:table_info(Table, storage_type) of
         Copies ->
             ok;

+ 1 - 0
changes/ce/fix-11158.en.md

@@ -0,0 +1 @@
+Wait for Mria table when the mnesia backend of retainer starts to avoid a possible error of the retainer when joining a cluster.