summaryrefslogtreecommitdiff
path: root/src/mongo/db/exec/batched_delete_stage.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/exec/batched_delete_stage.cpp')
-rw-r--r--src/mongo/db/exec/batched_delete_stage.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/mongo/db/exec/batched_delete_stage.cpp b/src/mongo/db/exec/batched_delete_stage.cpp
index b12a5c0d73b..7c1141e0f99 100644
--- a/src/mongo/db/exec/batched_delete_stage.cpp
+++ b/src/mongo/db/exec/batched_delete_stage.cpp
@@ -325,7 +325,8 @@ long long BatchedDeleteStage::_commitBatch(WorkingSetID* out,
// Start a WUOW with 'groupOplogEntries' which groups a delete batch into a single timestamp
// and oplog entry.
- WriteUnitOfWork wuow(opCtx(), true /* groupOplogEntries */);
+ WriteUnitOfWork wuow(opCtx(),
+ _stagedDeletesBuffer.size() > 1U ? true : false /* groupOplogEntries */);
for (; *bufferOffset < _stagedDeletesBuffer.size(); ++*bufferOffset) {
if (MONGO_unlikely(throwWriteConflictExceptionInBatchedDeleteStage.shouldFail())) {
throwWriteConflictException(