summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_change_stream_transform.cpp
diff options
context:
space:
mode:
authorBernard Gorman <bernard.gorman@gmail.com>2019-01-15 23:54:23 +0000
committerBernard Gorman <bernard.gorman@gmail.com>2019-02-02 20:44:19 +0000
commitfbb9daeb791d16c49b861d82c097cf9bd9daf07e (patch)
tree660bb996be48530e2e1eb5c1c9fc303912c1812c /src/mongo/db/pipeline/document_source_change_stream_transform.cpp
parent603a1d610e9ebfa7b43d4e5df0df2a5477622303 (diff)
downloadmongo-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.cpp9
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);