diff options
| author | Matthew Russotto <matthew.russotto@10gen.com> | 2017-08-25 16:31:43 -0400 |
|---|---|---|
| committer | Matthew Russotto <matthew.russotto@10gen.com> | 2017-08-25 18:04:04 -0400 |
| commit | ec42f5f16ff7809c5b1ed29601978e9e98aa5925 (patch) | |
| tree | f7dda10f0ff8d5cf3b387806612e2b7f367afafb | |
| parent | 46cd31827e62a02e826b44f6129f06623e8f2f78 (diff) | |
| download | mongo-ec42f5f16ff7809c5b1ed29601978e9e98aa5925.tar.gz | |
SERVER-30847 Start changeStreams at the lastAppliedOpTime not the lastDurableOpTime
| -rw-r--r-- | src/mongo/db/pipeline/document_source_change_stream.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/mongo/db/pipeline/document_source_change_stream.cpp b/src/mongo/db/pipeline/document_source_change_stream.cpp index d050e9d0356..acd55b63326 100644 --- a/src/mongo/db/pipeline/document_source_change_stream.cpp +++ b/src/mongo/db/pipeline/document_source_change_stream.cpp @@ -234,7 +234,7 @@ list<intrusive_ptr<DocumentSource>> DocumentSourceChangeStream::createFromBson( auto replCoord = repl::ReplicationCoordinator::get(expCtx->opCtx); uassert(40573, "The $changeStream stage is only supported on replica sets", replCoord); - Timestamp startFrom = replCoord->getLastCommittedOpTime().getTimestamp(); + Timestamp startFrom = replCoord->getMyLastAppliedOpTime().getTimestamp(); intrusive_ptr<DocumentSource> resumeStage = nullptr; auto spec = DocumentSourceChangeStreamSpec::parse(IDLParserErrorContext("$changeStream"), |