diff --git a/apps/emqx_node_rebalance/src/emqx_node_rebalance.app.src b/apps/emqx_node_rebalance/src/emqx_node_rebalance.app.src index 381001b87..69cf91f4c 100644 --- a/apps/emqx_node_rebalance/src/emqx_node_rebalance.app.src +++ b/apps/emqx_node_rebalance/src/emqx_node_rebalance.app.src @@ -1,6 +1,6 @@ {application, emqx_node_rebalance, [ {description, "EMQX Node Rebalance"}, - {vsn, "5.0.0"}, + {vsn, "5.0.1"}, {registered, [ emqx_node_rebalance_sup, emqx_node_rebalance, diff --git a/apps/emqx_node_rebalance/src/emqx_node_rebalance.erl b/apps/emqx_node_rebalance/src/emqx_node_rebalance.erl index 1f2adc565..70c022308 100644 --- a/apps/emqx_node_rebalance/src/emqx_node_rebalance.erl +++ b/apps/emqx_node_rebalance/src/emqx_node_rebalance.erl @@ -267,6 +267,9 @@ evict_conns(#{donors := DonorNodes, recipients := RecipientNodes, opts := Opts} ConnEvictRate = maps:get(conn_evict_rate, Opts), NodesToEvict = nodes_to_evict(RecipientAvg, DonorNodeCounts), ?SLOG(warning, #{ + donor_conn_avg => DonorAvg, + recipient_conn_avg => RecipientAvg, + thresholds => Thresholds, msg => "node_rebalance_evict_conns", nodes => NodesToEvict, counts => ConnEvictRate @@ -297,6 +300,9 @@ evict_sessions(#{donors := DonorNodes, recipients := RecipientNodes, opts := Opt SessEvictRate = maps:get(sess_evict_rate, Opts), NodesToEvict = nodes_to_evict(RecipientAvg, DonorNodeCounts), ?SLOG(warning, #{ + donor_sess_avg => DonorAvg, + recipient_sess_avg => RecipientAvg, + thresholds => Thresholds, msg => "node_rebalance_evict_sessions", nodes => NodesToEvict, counts => SessEvictRate