Move queue initialization to restarting thread

src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp

@@ -59,6 +59,11 @@ void ReplicatedMergeTreeQueue::initialize(zkutil::ZooKeeperPtr zookeeper)
 {
     std::lock_guard lock(state_mutex);
 
+    /// Clear parts before setting new one
+    current_parts.clear();
+    virtual_parts.clear();
+
+    /// Get current parts state from zookeeper
     Strings parts = zookeeper->getChildren(replica_path + "/parts");
     for (const auto & part_name : parts)
     {

src/Storages/MergeTree/ReplicatedMergeTreeRestartingThread.cpp

@@ -174,6 +174,8 @@ bool ReplicatedMergeTreeRestartingThread::tryStartup()
 
         try
         {
+            storage.queue.initialize(zookeeper);
+
             storage.queue.load(zookeeper);
 
             /// pullLogsToQueue() after we mark replica 'is_active' (and after we repair if it was lost);

src/Storages/StorageReplicatedMergeTree.cpp

@@ -4285,8 +4285,6 @@ void StorageReplicatedMergeTree::startup()
 
     try
     {
-        queue.initialize(getZooKeeper());
-
         InterserverIOEndpointPtr data_parts_exchange_ptr = std::make_shared<DataPartsExchange::Service>(*this);
         [[maybe_unused]] auto prev_ptr = std::atomic_exchange(&data_parts_exchange_endpoint, data_parts_exchange_ptr);
         assert(prev_ptr == nullptr);