diff --git a/apps/emqx/integration_test/emqx_persistent_session_ds_SUITE.erl b/apps/emqx/integration_test/emqx_persistent_session_ds_SUITE.erl
index 730cc9e38..736c911ff 100644
--- a/apps/emqx/integration_test/emqx_persistent_session_ds_SUITE.erl
+++ b/apps/emqx/integration_test/emqx_persistent_session_ds_SUITE.erl
@@ -644,7 +644,7 @@ t_session_replay_retry(_Config) ->
 
     Pubs0 = emqx_common_test_helpers:wait_publishes(NClients, 5_000),
     NPubs = length(Pubs0),
-    ?assertEqual(NClients, NPubs, ?drainMailbox()),
+    ?assertEqual(NClients, NPubs, ?drainMailbox(1_500)),
 
     ok = emqtt:stop(ClientSub),