diff options
| author | Charlie Swanson <charlie.swanson@mongodb.com> | 2018-04-10 13:25:49 -0400 |
|---|---|---|
| committer | Charlie Swanson <charlie.swanson@mongodb.com> | 2018-04-12 14:00:17 -0400 |
| commit | ec25294c8d0c1c60ff786ea99198749dc4788dd1 (patch) | |
| tree | 7d7f55565974f226f3c8c9fb60e36c4f33ded665 /jstests/sharding/change_streams_shards_start_in_sync.js | |
| parent | 49ab42843f85a50a215687ddbd1dd5db6a94738c (diff) | |
| download | mongo-ec25294c8d0c1c60ff786ea99198749dc4788dd1.tar.gz | |
SERVER-34181 Include 'clusterTime' in each change stream
Diffstat (limited to 'jstests/sharding/change_streams_shards_start_in_sync.js')
| -rw-r--r-- | jstests/sharding/change_streams_shards_start_in_sync.js | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/jstests/sharding/change_streams_shards_start_in_sync.js b/jstests/sharding/change_streams_shards_start_in_sync.js index efad4a2e382..93e26ec9e7c 100644 --- a/jstests/sharding/change_streams_shards_start_in_sync.js +++ b/jstests/sharding/change_streams_shards_start_in_sync.js @@ -52,7 +52,8 @@ function checkStream() { db = db.getSiblingDB(jsTestName()); let coll = db[jsTestName()]; - let changeStream = coll.aggregate([{$changeStream: {}}, {$project: {_id: 0}}]); + let changeStream = + coll.aggregate([{$changeStream: {}}, {$project: {_id: 0, clusterTime: 0}}]); assert.soon(() => changeStream.hasNext()); assert.docEq(changeStream.next(), { |