From 39259f66fa8ccd13818b8a5681b81fa020a8d4d2 Mon Sep 17 00:00:00 2001 From: Eric Eastwood Date: Wed, 26 Jun 2024 01:16:46 -0500 Subject: [PATCH] Join both tables with stream_ordering --- synapse/storage/databases/main/stream.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/synapse/storage/databases/main/stream.py b/synapse/storage/databases/main/stream.py index c5e6537980..2646dfd9cb 100644 --- a/synapse/storage/databases/main/stream.py +++ b/synapse/storage/databases/main/stream.py @@ -831,7 +831,7 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore): e.sender FROM current_state_delta_stream AS s INNER JOIN events AS e ON e.stream_ordering = s.stream_id - INNER JOIN room_memberships AS m ON m.event_id = e.event_id + INNER JOIN room_memberships AS m ON m.event_stream_ordering = s.stream_id WHERE m.user_id = ? AND s.stream_id > ? AND s.stream_id <= ? ORDER BY s.stream_id ASC