diff --git a/src/main/java/org/opendatakit/aggregate/odktables/DataManager.java b/src/main/java/org/opendatakit/aggregate/odktables/DataManager.java
index 5da26d101..7ecc5392b 100644
--- a/src/main/java/org/opendatakit/aggregate/odktables/DataManager.java
+++ b/src/main/java/org/opendatakit/aggregate/odktables/DataManager.java
@@ -1601,9 +1601,11 @@ public ChangeSetList getChangeSetsSince(String dataETag, String sequenceValue) t
       
       Query query;
       if (unifiedSequenceValue == null) {
-        query = buildRowsFromBeginningQuery(logTable, entry, true);
+        query = logTable.query("DataManager.getChangesetsSinceBeginning", cc);
+        query.greaterThanOrEqual(DbLogTable.SEQUENCE_VALUE, entry.getAprioriDataSequenceValue());
       } else {
-        query = buildRowsSinceQuery(logTable, unifiedSequenceValue, true);
+        query = logTable.query("DataManager.getChangesetsSinceQuery", cc);
+        query.greaterThan(DbLogTable.SEQUENCE_VALUE, unifiedSequenceValue);
       }
       
       result = query.getDistinct(DbLogTable.DATA_ETAG_AT_MODIFICATION);
@@ -1745,4 +1747,4 @@ public WebsafeRows getChangeSetRows(String dataETag, boolean isActive,
     return new WebsafeRows(computeDiff(rows), currentDataETag, result.websafeRefetchCursor,
         result.websafeBackwardCursor, result.websafeResumeCursor, result.hasMore, result.hasPrior);
   }
-}
\ No newline at end of file
+}