From 2e2f3cb2aadd1386e631da2e5874a3b9a85e7534 Mon Sep 17 00:00:00 2001
From: ieQu1 <99872536+ieQu1@users.noreply.github.com>
Date: Sat, 3 Feb 2024 19:32:17 +0100
Subject: [PATCH] fix(sessds): Avoid stream hash collisions

---
 apps/emqx/src/emqx_persistent_session_ds_stream_scheduler.erl | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/apps/emqx/src/emqx_persistent_session_ds_stream_scheduler.erl b/apps/emqx/src/emqx_persistent_session_ds_stream_scheduler.erl
index 315fcbc78..45bf6ede1 100644
--- a/apps/emqx/src/emqx_persistent_session_ds_stream_scheduler.erl
+++ b/apps/emqx/src/emqx_persistent_session_ds_stream_scheduler.erl
@@ -169,7 +169,7 @@ del_subscription(SubId, S0) ->
 
 ensure_iterator(TopicFilter, StartTime, SubId, {{RankX, RankY}, Stream}, S) ->
     %% TODO: hash collisions
-    Key = {SubId, erlang:phash2(Stream)},
+    Key = {SubId, Stream},
     case emqx_persistent_session_ds_state:get_stream(Key, S) of
         undefined ->
             ?SLOG(debug, #{