Explorar el Código

Merge pull request #8081 from zhongwencool/cluster-rpc-catchup-latestid

fix: always commit to TargetTnxId when init
zhongwencool hace 3 años
padre
commit
a6f43e3fc8
Se han modificado 1 ficheros con 1 adiciones y 7 borrados
  1. 1 7
      apps/emqx_conf/src/emqx_cluster_rpc.erl

+ 1 - 7
apps/emqx_conf/src/emqx_cluster_rpc.erl

@@ -512,11 +512,5 @@ get_retry_ms() ->
 
 maybe_init_tnx_id(_Node, TnxId) when TnxId < 0 -> ok;
 maybe_init_tnx_id(Node, TnxId) ->
-    {atomic, _} = transaction(fun init_node_tnx_id/2, [Node, TnxId]),
+    {atomic, _} = transaction(fun commit/2, [Node, TnxId]),
     ok.
-
-init_node_tnx_id(Node, TnxId) ->
-    case mnesia:read(?CLUSTER_COMMIT, Node) of
-        [] -> commit(Node, TnxId);
-        _ -> ok
-    end.