summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/session_catalog_migration_source.cpp
diff options
context:
space:
mode:
authorEthan Zhang <ethan.zhang@mongodb.com>2021-10-12 22:42:05 -0500
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-10-13 04:23:37 +0000
commita0453fb2b7c8891b0088de7543137bc7ad37d902 (patch)
treea9b105666dbb8966c0b7c871fdd3301b66f2ce9a /src/mongo/db/s/session_catalog_migration_source.cpp
parent2e9edd836eaf872f3f30077e3ee22c79578705df (diff)
downloadmongo-a0453fb2b7c8891b0088de7543137bc7ad37d902.tar.gz
Revert "SERVER-56127 Fixing retryable writes on update and delete commands to not execute more than once"
This reverts commit fedd7fa7eaf29751d3573ff39f18c3f09abbf06c.
Diffstat (limited to 'src/mongo/db/s/session_catalog_migration_source.cpp')
-rw-r--r--src/mongo/db/s/session_catalog_migration_source.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/mongo/db/s/session_catalog_migration_source.cpp b/src/mongo/db/s/session_catalog_migration_source.cpp
index c33424ee7e9..c257fc08404 100644
--- a/src/mongo/db/s/session_catalog_migration_source.cpp
+++ b/src/mongo/db/s/session_catalog_migration_source.cpp
@@ -335,7 +335,8 @@ bool SessionCatalogMigrationSource::_handleWriteHistory(WithLock, OperationConte
}
if (nextOplog->isCrudOpType()) {
- auto shardKey = _keyPattern.extractShardKeyFromOplogEntry(*nextOplog);
+ auto shardKey =
+ _keyPattern.extractShardKeyFromDoc(nextOplog->getObjectContainingDocumentKey());
if (!_chunkRange.containsKey(shardKey)) {
continue;
}