yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(ft-fs): use `emqx:running_nodes()` as default cluster view 

When iterating over complete exports cluster-wide.
This commit is contained in:
Andrew Mayorov 2023-06-14 22:10:48 +03:00
parent bf62cdc3e3
commit 52354bf58a
No known key found for this signature in database
GPG Key ID: 2837C62ACFBFED5D
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_ft/src/emqx_ft_assembler.erl
View File

@ -96,7 +96,7 @@ handle_event(
complete -> complete ->
{next_state, start_assembling, NSt, ?internal([])}; {next_state, start_assembling, NSt, ?internal([])};
{incomplete, _} -> {incomplete, _} ->
Nodes = mria_mnesia:running_nodes() -- [node()], Nodes = emqx:running_nodes() -- [node()],
{next_state, {list_remote_fragments, Nodes}, NSt, ?internal([])}; {next_state, {list_remote_fragments, Nodes}, NSt, ?internal([])};
% TODO: recovery? % TODO: recovery?
{error, _} = Error -> {error, _} = Error ->

2
apps/emqx_ft/src/emqx_ft_storage_exporter_fs.erl
View File

@ -361,7 +361,7 @@ list(_Options, Query) ->
end. end.
list(QueryIn) -> list(QueryIn) ->
{Nodes, NodeQuery} = decode_query(QueryIn, lists:sort(mria_mnesia:running_nodes())), {Nodes, NodeQuery} = decode_query(QueryIn, lists:sort(emqx:running_nodes())),
list_nodes(NodeQuery, Nodes, #{items => []}). list_nodes(NodeQuery, Nodes, #{items => []}).
list_nodes(Query, Nodes = [Node | Rest], Acc) -> list_nodes(Query, Nodes = [Node | Rest], Acc) ->