diff --git a/apps/emqx/src/emqx_persistent_session_ds/emqx_persistent_session_ds_shared_subs.erl b/apps/emqx/src/emqx_persistent_session_ds/emqx_persistent_session_ds_shared_subs.erl index 6cf5cc40b..1f4d6f6e9 100644 --- a/apps/emqx/src/emqx_persistent_session_ds/emqx_persistent_session_ds_shared_subs.erl +++ b/apps/emqx/src/emqx_persistent_session_ds/emqx_persistent_session_ds_shared_subs.erl @@ -304,9 +304,10 @@ renew_streams(S0, #{agent := Agent0, scheduled_actions := ScheduledActions} = Sh {StreamLeaseEvents, Agent1} = emqx_persistent_session_ds_shared_subs_agent:renew_streams( Agent0 ), - ?tp(warning, shared_subs_new_stream_lease_events, #{ - stream_lease_events => format_lease_events(StreamLeaseEvents) - }), + StreamLeaseEvents =/= [] andalso + ?tp(warning, shared_subs_new_stream_lease_events, #{ + stream_lease_events => format_lease_events(StreamLeaseEvents) + }), S1 = lists:foldl( fun (#{type := lease} = Event, S) -> accept_stream(Event, S, ScheduledActions);