SERVER-62272 : Migration OK for chunks existing before schema validator

(cherry picked from commit bc1ac6fb2eb66202d1acc08d158b102c57beabbd)

1 files changed, 13 insertions, 6 deletions

diff --git a/src/mongo/db/s/migration_destination_manager.cpp b/src/mongo/db/s/migration_destination_manager.cpp
index 35f945bccd9..49c2d1dcf76 100644
--- a/src/mongo/db/s/migration_destination_manager.cpp
+++ b/src/mongo/db/s/migration_destination_manager.cpp
@@ -841,15 +841,20 @@ void MigrationDestinationManager::_migrateDriver(OperationContext* opCtx) {
                     }
                     return toInsert;
                 }());
+                {
+                    // Disable the schema validation for opCtx for performInserts()
+                    DisableDocumentValidation documentValidationDisabler(opCtx);
 
-                const WriteResult reply = performInserts(opCtx, insertOp, true);
+                    const WriteResult reply = performInserts(opCtx, insertOp, true);
 
-                for (unsigned long i = 0; i < reply.results.size(); ++i) {
-                    uassertStatusOKWithContext(
-                        reply.results[i],
-                        str::stream() << "Insert of " << insertOp.getDocuments()[i] << " failed.");
+                    for (unsigned long i = 0; i < reply.results.size(); ++i) {
+                        uassertStatusOKWithContext(reply.results[i],
+                                                   str::stream()
+                                                       << "Insert of " << insertOp.getDocuments()[i]
+                                                       << " failed.");
+                    }
+                    // Revert to the original validation settings for opCtx
                 }
-
                 {
                     stdx::lock_guard<Latch> statsLock(_mutex);
                     _numCloned += batchNumCloned;
@@ -1058,6 +1063,8 @@ bool MigrationDestinationManager::_applyMigrateOp(OperationContext* opCtx,
 
     bool didAnything = false;
 
+    DisableDocumentValidation documentValidationDisabler(opCtx);
+
     // Deleted documents
     if (xfer["deleted"].isABSONObj()) {
         boost::optional<RemoveSaver> rs;