diff --git a/syncapi/storage/postgres/relations_table.go b/syncapi/storage/postgres/relations_table.go
index 2b710a3a9..97f5b828f 100644
--- a/syncapi/storage/postgres/relations_table.go
+++ b/syncapi/storage/postgres/relations_table.go
@@ -68,7 +68,7 @@ const selectThreadsSQL = "" +
 	" JOIN syncapi_output_room_events ON syncapi_output_room_events.event_id = syncapi_relations.event_id" +
 	" WHERE syncapi_relations.room_id = $1" +
 	" AND syncapi_relations.rel_type = 'm.thread'" +
-	" AND syncapi_relations.id >= $2 AND" +
+	" AND syncapi_relations.id >= $2" +
 	" ORDER BY syncapi_relations.id LIMIT $3"
 
 const selectThreadsWithSenderSQL = "" +
diff --git a/syncapi/storage/sqlite3/relations_table.go b/syncapi/storage/sqlite3/relations_table.go
index 512178c5b..917ac2bc5 100644
--- a/syncapi/storage/sqlite3/relations_table.go
+++ b/syncapi/storage/sqlite3/relations_table.go
@@ -69,7 +69,7 @@ const selectThreadsSQL = "" +
 	" JOIN syncapi_output_room_events ON syncapi_output_room_events.event_id = syncapi_relations.event_id" +
 	" WHERE syncapi_relations.room_id = $1" +
 	" AND syncapi_relations.rel_type = 'm.thread'" +
-	" AND syncapi_relations.id >= $2 AND" +
+	" AND syncapi_relations.id >= $2" +
 	" ORDER BY syncapi_relations.id LIMIT $3"
 
 const selectThreadsWithSenderSQL = "" +