SERVER-62178 Clear filtering metadata on recipient shard primary for temporary resharding collection after creation

(cherry picked from commit e9d49578b3e11044e0e41bdcbb72f41cd17e571c)

2 files changed, 17 insertions, 15 deletions

diff --git a/src/mongo/db/s/resharding/resharding_recipient_service_external_state.cpp b/src/mongo/db/s/resharding/resharding_recipient_service_external_state.cpp
index 06b08fe4f66..2dc584953d6 100644
--- a/src/mongo/db/s/resharding/resharding_recipient_service_external_state.cpp
+++ b/src/mongo/db/s/resharding/resharding_recipient_service_external_state.cpp
@@ -85,6 +85,10 @@ void ReshardingRecipientService::RecipientStateMachineExternalState::
                                     std::move(indexes),
                                     std::move(idIndex),
                                     std::move(collOptions)});
+
+    AutoGetCollection autoColl(opCtx, metadata.getTempReshardingNss(), MODE_IX);
+    CollectionShardingRuntime::get(opCtx, metadata.getTempReshardingNss())
+        ->clearFilteringMetadata(opCtx);
 }
 
 template <typename Callable>
diff --git a/src/mongo/db/s/resharding/resharding_recipient_service_external_state_test.cpp b/src/mongo/db/s/resharding/resharding_recipient_service_external_state_test.cpp
index 80ae276c5a3..4035fe97d51 100644
--- a/src/mongo/db/s/resharding/resharding_recipient_service_external_state_test.cpp
+++ b/src/mongo/db/s/resharding/resharding_recipient_service_external_state_test.cpp
@@ -248,6 +248,14 @@ public:
         }
         ASSERT_EQ(indexesCopy.size(), 0);
     }
+
+    void verifyTempReshardingCollectionAndMetadata() {
+        RecipientStateMachineExternalStateImpl externalState;
+        externalState.ensureTempReshardingCollectionExistsWithIndexes(
+            operationContext(), kMetadata, kDefaultFetchTimestamp);
+        CollectionShardingRuntime csr(getServiceContext(), kOrigNss, executor());
+        ASSERT(csr.getCurrentMetadataIfKnown() == boost::none);
+    }
 };
 
 TEST_F(RecipientServiceExternalStateTest, ReshardingConfigServerUpdatesHaveNoTimeout) {
@@ -313,9 +321,7 @@ TEST_F(RecipientServiceExternalStateTest, CreateLocalReshardingCollectionBasic)
         expectListIndexes(kOrigNss, kOrigUUID, indexes, HostAndPort(shards[0].getHost()));
     });
 
-    RecipientStateMachineExternalStateImpl externalState;
-    externalState.ensureTempReshardingCollectionExistsWithIndexes(
-        operationContext(), kMetadata, kDefaultFetchTimestamp);
+    verifyTempReshardingCollectionAndMetadata();
 
     future.default_timed_get();
 
@@ -372,9 +378,7 @@ TEST_F(RecipientServiceExternalStateTest,
         expectListIndexes(kOrigNss, kOrigUUID, indexes, HostAndPort(shards[0].getHost()));
     });
 
-    RecipientStateMachineExternalStateImpl externalState;
-    externalState.ensureTempReshardingCollectionExistsWithIndexes(
-        operationContext(), kMetadata, kDefaultFetchTimestamp);
+    verifyTempReshardingCollectionAndMetadata();
 
     future.default_timed_get();
 
@@ -440,9 +444,7 @@ TEST_F(RecipientServiceExternalStateTest,
         expectListIndexes(kOrigNss, kOrigUUID, indexes, HostAndPort(shards[0].getHost()));
     });
 
-    RecipientStateMachineExternalStateImpl externalState;
-    externalState.ensureTempReshardingCollectionExistsWithIndexes(
-        operationContext(), kMetadata, kDefaultFetchTimestamp);
+    verifyTempReshardingCollectionAndMetadata();
 
     future.default_timed_get();
 
@@ -510,9 +512,7 @@ TEST_F(RecipientServiceExternalStateTest,
         expectListIndexes(kOrigNss, kOrigUUID, indexes, HostAndPort(shards[0].getHost()));
     });
 
-    RecipientStateMachineExternalStateImpl externalState;
-    externalState.ensureTempReshardingCollectionExistsWithIndexes(
-        operationContext(), kMetadata, kDefaultFetchTimestamp);
+    verifyTempReshardingCollectionAndMetadata();
 
     future.default_timed_get();
 
@@ -570,9 +570,7 @@ TEST_F(RecipientServiceExternalStateTest,
         expectListIndexes(kOrigNss, kOrigUUID, indexes, HostAndPort(shards[0].getHost()));
     });
 
-    RecipientStateMachineExternalStateImpl externalState;
-    externalState.ensureTempReshardingCollectionExistsWithIndexes(
-        operationContext(), kMetadata, kDefaultFetchTimestamp);
+    verifyTempReshardingCollectionAndMetadata();
 
     future.default_timed_get();