SERVER-47056: Do not use readOnce cursors for collection scan in initial sync

(cherry picked from commit 950522e1e4a478673efd5da46469635b9a15bb6a)

1 files changed, 4 insertions, 5 deletions

diff --git a/src/mongo/db/repl/collection_cloner.cpp b/src/mongo/db/repl/collection_cloner.cpp
index a54b026999d..c8e3d69aadf 100644
--- a/src/mongo/db/repl/collection_cloner.cpp
+++ b/src/mongo/db/repl/collection_cloner.cpp
@@ -212,19 +212,18 @@ BaseCloner::AfterStageBehavior CollectionCloner::queryStage() {
 
 void CollectionCloner::runQuery() {
     // Non-resumable query.
-    Query query = QUERY("query" << BSONObj() << "$readOnce" << true);
+    Query query;
 
     if (_resumeSupported) {
         if (_resumeToken) {
             // Resume the query from where we left off.
             LOGV2_DEBUG(21133, 1, "Collection cloner will resume the last successful query");
-            query = QUERY("query" << BSONObj() << "$readOnce" << true << "$_requestResumeToken"
-                                  << true << "$_resumeAfter" << _resumeToken.get());
+            query = QUERY("query" << BSONObj() << "$_requestResumeToken" << true << "$_resumeAfter"
+                                  << _resumeToken.get());
         } else {
             // New attempt at a resumable query.
             LOGV2_DEBUG(21134, 1, "Collection cloner will run a new query");
-            query = QUERY("query" << BSONObj() << "$readOnce" << true << "$_requestResumeToken"
-                                  << true);
+            query = QUERY("query" << BSONObj() << "$_requestResumeToken" << true);
         }
         query.hint(BSON("$natural" << 1));
     }