SERVER-46137 Implement ReplicaSetNodeProcessInterface methods needed for $merge46137

1 files changed, 3 insertions, 1 deletions

diff --git a/src/mongo/db/db.cpp b/src/mongo/db/db.cpp
index b7f1c0945c8..cc005a763ab 100644
--- a/src/mongo/db/db.cpp
+++ b/src/mongo/db/db.cpp
@@ -968,9 +968,11 @@ void setUpReplication(ServiceContext* serviceContext) {
         SecureRandom().nextInt64());
     // Only create a ReplicaSetNodeExecutor if sharding is disabled and replication is enabled.
     // Note that sharding sets up its own executors for scheduling work to remote nodes.
-    if (serverGlobalParams.clusterRole == ClusterRole::None && replCoord->isReplEnabled())
+    if (serverGlobalParams.clusterRole == ClusterRole::None && replCoord->isReplEnabled()) {
         ReplicaSetNodeProcessInterface::setReplicaSetNodeExecutor(
             serviceContext, makeReplicaSetNodeExecutor(serviceContext));
+        ReplicaSetNodeProcessInterface::getReplicaSetNodeExecutor(serviceContext)->startup();
+    }
 
     repl::ReplicationCoordinator::set(serviceContext, std::move(replCoord));
     repl::setOplogCollectionName(serviceContext);