diff --git a/packages/mongo-livedata/oplog_tailing.js b/packages/mongo-livedata/oplog_tailing.js index b8dab965e72..e4610385214 100644 --- a/packages/mongo-livedata/oplog_tailing.js +++ b/packages/mongo-livedata/oplog_tailing.js @@ -176,7 +176,7 @@ _.extend(OplogHandle.prototype, { // Find the last oplog entry. var lastOplogEntry = self._oplogLastEntryConnection.findOne( - OPLOG_COLLECTION, {}, {sort: {$natural: -1}}); + OPLOG_COLLECTION, {}, {sort: {$natural: -1}, fields: {ts: 1}}); var oplogSelector = _.clone(self._baseOplogSelector); if (lastOplogEntry) {