summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_change_stream.h
diff options
context:
space:
mode:
authorBernard Gorman <bernard.gorman@gmail.com>2017-11-26 04:18:35 +0000
committerBernard Gorman <bernard.gorman@gmail.com>2017-12-06 09:09:20 +0000
commita18859168f73428522d4338fee982329d9d431ed (patch)
tree31d85ddbe969bba1ea3c4d2606632cc6aa21fbc0 /src/mongo/db/pipeline/document_source_change_stream.h
parenta34fa65325dafc01857a4525d0d8b2f26b485965 (diff)
downloadmongo-a18859168f73428522d4338fee982329d9d431ed.tar.gz
SERVER-32085 $changeStream reports incorrect documentKey for unsharded collections that become sharded
Diffstat (limited to 'src/mongo/db/pipeline/document_source_change_stream.h')
-rw-r--r--src/mongo/db/pipeline/document_source_change_stream.h3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/mongo/db/pipeline/document_source_change_stream.h b/src/mongo/db/pipeline/document_source_change_stream.h
index 23ac499c804..17f891c7dc7 100644
--- a/src/mongo/db/pipeline/document_source_change_stream.h
+++ b/src/mongo/db/pipeline/document_source_change_stream.h
@@ -102,6 +102,9 @@ public:
// sharded, and anyway "_id". Empty until the first oplog entry with a uuid is encountered.
// Needed for transforming 'insert' oplog entries.
std::vector<FieldPath> _documentKeyFields;
+
+ // Set to true if the collection is found to be sharded while retrieving _documentKeyFields.
+ bool _documentKeyFieldsSharded = false;
};
// The sort pattern used to merge results from multiple change streams on a mongos.