From 52354bf58a0865ac5c0299dbfe4a9494a9a2e894 Mon Sep 17 00:00:00 2001 From: Andrew Mayorov Date: Wed, 14 Jun 2023 22:10:48 +0300 Subject: [PATCH] fix(ft-fs): use `emqx:running_nodes()` as default cluster view When iterating over complete exports cluster-wide. --- apps/emqx_ft/src/emqx_ft_assembler.erl | 2 +- apps/emqx_ft/src/emqx_ft_storage_exporter_fs.erl | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/emqx_ft/src/emqx_ft_assembler.erl b/apps/emqx_ft/src/emqx_ft_assembler.erl index c96df224c..0d9e86a49 100644 --- a/apps/emqx_ft/src/emqx_ft_assembler.erl +++ b/apps/emqx_ft/src/emqx_ft_assembler.erl @@ -96,7 +96,7 @@ handle_event( complete -> {next_state, start_assembling, NSt, ?internal([])}; {incomplete, _} -> - Nodes = mria_mnesia:running_nodes() -- [node()], + Nodes = emqx:running_nodes() -- [node()], {next_state, {list_remote_fragments, Nodes}, NSt, ?internal([])}; % TODO: recovery? {error, _} = Error -> diff --git a/apps/emqx_ft/src/emqx_ft_storage_exporter_fs.erl b/apps/emqx_ft/src/emqx_ft_storage_exporter_fs.erl index 589949bda..e37ba25af 100644 --- a/apps/emqx_ft/src/emqx_ft_storage_exporter_fs.erl +++ b/apps/emqx_ft/src/emqx_ft_storage_exporter_fs.erl @@ -361,7 +361,7 @@ list(_Options, Query) -> end. 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(Query, Nodes = [Node | Rest], Acc) ->