Add a sleep to the commitTransaction command: diff --git a/src/mongo/db/commands/txn_cmds.cpp b/src/mongo/db/commands/txn_cmds.cpp index 62fabeb627..9b1ed18870 100644 --- a/src/mongo/db/commands/txn_cmds.cpp +++ b/src/mongo/db/commands/txn_cmds.cpp @@ -80,6 +80,8 @@ public : uassert( ErrorCodes::CommandFailed, "commitTransaction must be run within a session" , session); + opCtx->sleepFor(Milliseconds(2000)); + // commitTransaction is retryable. if (session->transactionIsCommitted()) { // We set the client last op to the last optime observed by the system to ensure that Then run the following test: (function() { "use strict" ; var replTest = new ReplSetTest({nodes: 1}); replTest.startSet(); replTest.initiate(); var primary = replTest.getPrimary(); assert .commandWorked(primary.adminCommand({setParameter: 1, transactionLifetimeLimitSeconds: 1})); const session = primary.getDB( "test" ).getMongo().startSession(); const sessionDb = session.getDatabase( "test" ); assert .commandWorked(sessionDb.createCollection( "c" )); session.startTransaction(); assert .commandWorked(sessionDb.c.insert({a: 1})); assert .commandWorked(sessionDb.adminCommand({commitTransaction: 1, writeConcern: {w: "majority" }})); session.commitTransaction(); replTest.stopSet(); })();