summary refs log tree commit diff
path: root/synapse/storage
diff options
context:
space:
mode:
authorBrendan Abolivier <babolivier@matrix.org>2019-10-30 17:28:41 +0000
committerBrendan Abolivier <babolivier@matrix.org>2019-10-30 17:28:41 +0000
commitfe51d6cacf6e1a2da5fc3589d0bc4118342b33dd (patch)
tree98ba7e3838518a0053015eec259f932bbb299cd8 /synapse/storage
parentAdd integration tests for sync (diff)
downloadsynapse-fe51d6cacf6e1a2da5fc3589d0bc4118342b33dd.tar.xz
Add more integration testing
Diffstat (limited to 'synapse/storage')
-rw-r--r--synapse/storage/data_stores/main/stream.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/storage/data_stores/main/stream.py b/synapse/storage/data_stores/main/stream.py
index 907d7f20ba..cfa34ba1e7 100644
--- a/synapse/storage/data_stores/main/stream.py
+++ b/synapse/storage/data_stores/main/stream.py
@@ -872,7 +872,7 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore):
         args.append(int(limit))
 
         sql = (
-            "SELECT event_id, topological_ordering, stream_ordering"
+            "SELECT DISTINCT event_id, topological_ordering, stream_ordering"
             " FROM events"
             " LEFT JOIN event_labels USING (event_id)"
             " WHERE outlier = ? AND room_id = ? AND %(bounds)s"