diff options
| author | Denis Grebennicov <denis.grebennicov@mongodb.com> | 2022-04-04 17:04:22 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-04-04 17:37:27 +0000 |
| commit | 12fc3ef71b375ce012ad639ee1adfed555819503 (patch) | |
| tree | 11c04d1cf6f195a562cf35552c78e0898d2b40ba /src | |
| parent | 27c4c25165c03997820fde543a9d726df220826c (diff) | |
| download | mongo-12fc3ef71b375ce012ad639ee1adfed555819503.tar.gz | |
SERVER-65217 Run expired pre-images deletion job with multi-deletes support only if feature flag is enabled
Diffstat (limited to 'src')
| -rw-r--r-- | src/mongo/db/pipeline/change_stream_expired_pre_image_remover.cpp | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/src/mongo/db/pipeline/change_stream_expired_pre_image_remover.cpp b/src/mongo/db/pipeline/change_stream_expired_pre_image_remover.cpp index ed65baf5abb..1ee6d154052 100644 --- a/src/mongo/db/pipeline/change_stream_expired_pre_image_remover.cpp +++ b/src/mongo/db/pipeline/change_stream_expired_pre_image_remover.cpp @@ -346,8 +346,6 @@ void deleteExpiredChangeStreamPreImages(Client* client, Date_t currentTimeForTim ->getEarliestOplogTimestamp(opCtx.get()); const bool isBatchedRemoval = gBatchedExpiredChangeStreamPreImageRemoval.load(); - const bool isMultiDeletesFeatureFlagEnabled = - feature_flags::gBatchMultiDeletes.isEnabled(serverGlobalParams.featureCompatibility); size_t numberOfRemovals = 0; ChangeStreamExpiredPreImageIterator expiredPreImages( @@ -367,7 +365,7 @@ void deleteExpiredChangeStreamPreImages(Client* client, Date_t currentTimeForTim params->isMulti = true; boost::optional<std::unique_ptr<BatchedDeleteStageBatchParams>> batchParams; - if (isMultiDeletesFeatureFlagEnabled && isBatchedRemoval) { + if (isBatchedRemoval) { batchParams = std::make_unique<BatchedDeleteStageBatchParams>(); } |