diff options
| author | Hartek Sabharwal <hartek.sabharwal@mongodb.com> | 2021-03-15 14:58:10 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-03-15 15:37:45 +0000 |
| commit | 4909647aa8e1c119b8a7ed0f12bef3760546c6c9 (patch) | |
| tree | 28db543402ec4179a036eba0846729092d280652 /jstests/noPassthrough/change_streams_oplog_rollover.js | |
| parent | e2702b9a7e2d3b8f868efdd79757e3003bec2b21 (diff) | |
| download | mongo-4909647aa8e1c119b8a7ed0f12bef3760546c6c9.tar.gz | |
SERVER-55162 Retry getting 'firstOplogEntry' in oplog_rollover_agg.js
Diffstat (limited to 'jstests/noPassthrough/change_streams_oplog_rollover.js')
| -rw-r--r-- | jstests/noPassthrough/change_streams_oplog_rollover.js | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/jstests/noPassthrough/change_streams_oplog_rollover.js b/jstests/noPassthrough/change_streams_oplog_rollover.js index 5becd1f25d8..d483e345279 100644 --- a/jstests/noPassthrough/change_streams_oplog_rollover.js +++ b/jstests/noPassthrough/change_streams_oplog_rollover.js @@ -8,7 +8,7 @@ (function() { "use strict"; -load('jstests/replsets/rslib.js'); // For getLatestOp. +load('jstests/replsets/rslib.js'); // For getLatestOp, getFirstOplogEntry. load('jstests/libs/change_stream_util.js'); // For ChangeStreamTest. const oplogSize = 1; // size in MB @@ -66,8 +66,7 @@ for (let nextExpectedId of [4, 5]) { // Confirm that we can begin a stream at a timestamp that precedes the start of the oplog, if // the first entry in the oplog is the replica set initialization message. -const firstOplogEntry = - testDB.getSiblingDB("local").oplog.rs.find().sort({$natural: 1}).limit(1).toArray()[0]; +const firstOplogEntry = getFirstOplogEntry(rst.getPrimary()); assert.eq(firstOplogEntry.o.msg, "initiating set"); assert.eq(firstOplogEntry.op, "n"); |