diff options
author | Bernard Gorman <bernard.gorman@gmail.com> | 2019-01-15 23:54:23 +0000 |
---|---|---|
committer | Bernard Gorman <bernard.gorman@gmail.com> | 2019-02-02 20:44:19 +0000 |
commit | fbb9daeb791d16c49b861d82c097cf9bd9daf07e (patch) | |
tree | 660bb996be48530e2e1eb5c1c9fc303912c1812c /src/mongo/db/pipeline/document_source_change_stream_transform.cpp | |
parent | 603a1d610e9ebfa7b43d4e5df0df2a5477622303 (diff) | |
download | mongo-fbb9daeb791d16c49b861d82c097cf9bd9daf07e.tar.gz |
SERVER-38975 Include UUID in high water marks from shards where the collection does not exist
Diffstat (limited to 'src/mongo/db/pipeline/document_source_change_stream_transform.cpp')
-rw-r--r-- | src/mongo/db/pipeline/document_source_change_stream_transform.cpp | 9 |
1 files changed, 0 insertions, 9 deletions
diff --git a/src/mongo/db/pipeline/document_source_change_stream_transform.cpp b/src/mongo/db/pipeline/document_source_change_stream_transform.cpp index 493b284ba75..e9435d5ced2 100644 --- a/src/mongo/db/pipeline/document_source_change_stream_transform.cpp +++ b/src/mongo/db/pipeline/document_source_change_stream_transform.cpp @@ -349,15 +349,6 @@ Document DocumentSourceChangeStreamTransform::applyTransformation(const Document invariant(!uuid.missing(), "Saw a CRUD op without a UUID"); } - // If the collection did not exist when the change stream was opened, then the UUID will not - // have been obtained from the catalog. In this case, we set the UUID on the ExpressionContext - // after obtaining it from the first relevant oplog entry, so that the UUID can be included in - // high water mark tokens for change streams watching a single collection. The UUID is needed - // for resumability against a single collection due to collation semantics. - if (!pExpCtx->uuid && !uuid.missing() && pExpCtx->isSingleNamespaceAggregation()) { - pExpCtx->uuid = uuid.getUuid(); - } - // Note that 'documentKey' and/or 'uuid' might be missing, in which case they will not appear // in the output. auto resumeTokenData = getResumeToken(ts, uuid, documentKey); |