Update mria.erl

qzhuyan · qzhuyan · commit 39c76f0da870 · 2025-03-12T11:43:18.000+01:00
diff --git a/src/mria.erl b/src/mria.erl
@@ -595,7 +595,7 @@ should_retry_rpc(_) ->
 find_upstream_node(Shard) ->
     ?tp_span(find_upstream_node, #{shard => Shard},
              begin
-                 {ok, Node} = mria_status:get_core_node(Shard, infinity),
+                 {ok, Node} = mria_status:upstream(Shard),
                  Node
              end).
 
