diff options
| author | Bernard Gorman <bernard.gorman@gmail.com> | 2018-04-03 16:55:52 +0100 |
|---|---|---|
| committer | Bernard Gorman <bernard.gorman@gmail.com> | 2018-04-06 02:47:55 +0100 |
| commit | 41084e8f0fa354a9efc28a354321200e94a2fcf6 (patch) | |
| tree | 309fed55bfb25682117ca7a4c170c1699cadfbd6 /jstests/sharding/change_streams_primary_shard_unaware.js | |
| parent | 87be281e31034f80723d5299b70e7e956a48c494 (diff) | |
| download | mongo-41084e8f0fa354a9efc28a354321200e94a2fcf6.tar.gz | |
SERVER-34090 Allow resuming change stream when resume token's document key does not contain the shard key
Diffstat (limited to 'jstests/sharding/change_streams_primary_shard_unaware.js')
| -rw-r--r-- | jstests/sharding/change_streams_primary_shard_unaware.js | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/jstests/sharding/change_streams_primary_shard_unaware.js b/jstests/sharding/change_streams_primary_shard_unaware.js index 528f96edb1d..ec4027bb800 100644 --- a/jstests/sharding/change_streams_primary_shard_unaware.js +++ b/jstests/sharding/change_streams_primary_shard_unaware.js @@ -68,11 +68,8 @@ // Establish change stream cursor on the second mongos, which is not aware that the // collection is sharded. let cstMongos1 = new ChangeStreamTest(mongos1DB); - let cursorMongos1 = cstMongos1.startWatchingChanges({ - pipeline: [{$changeStream: {fullDocument: "updateLookup"}}], - collection: mongos1Coll, - includeToken: true - }); + let cursorMongos1 = cstMongos1.startWatchingChanges( + {pipeline: [{$changeStream: {fullDocument: "updateLookup"}}], collection: mongos1Coll}); assert.eq(0, cursorMongos1.firstBatch.length, "Cursor had changes: " + tojson(cursorMongos1)); // Establish a change stream cursor on the now sharded collection through the first mongos. |