summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp
diff options
context:
space:
mode:
authorJudah Schvimer <judah@mongodb.com>2019-05-07 17:36:07 -0400
committerJudah Schvimer <judah@mongodb.com>2019-05-07 17:36:07 -0400
commit19158a0271f4f240b3ab6f9109f7cf821af237a8 (patch)
treec5d988af8b08438d97cf758b967350b07930d257 /src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp
parentf80f6d084645dacff9572e7b1260492734a7e6b7 (diff)
downloadmongo-19158a0271f4f240b3ab6f9109f7cf821af237a8.tar.gz
SERVER-40248 Return correct operation to apply for update oplog entries
Diffstat (limited to 'src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp')
-rw-r--r--src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp b/src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp
index 57ba2ccd650..9e6e44388fd 100644
--- a/src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp
+++ b/src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp
@@ -92,7 +92,7 @@ bool shouldApplyOplogToSession(const repl::OplogEntry& oplog,
const ShardKeyPattern& keyPattern) {
// Skip appending CRUD operations that don't pertain to the ChunkRange being migrated.
if (oplog.isCrudOpType()) {
- auto shardKey = keyPattern.extractShardKeyFromDoc(oplog.getOperationToApply());
+ auto shardKey = keyPattern.extractShardKeyFromDoc(oplog.getObjectContainingDocumentKey());
if (!range.containsKey(shardKey)) {
return false;
}