diff --git a/dbms/src/Storages/StorageReplicatedMergeTree.cpp b/dbms/src/Storages/StorageReplicatedMergeTree.cpp
index 34c22703f1d..c20f82401b0 100644
--- a/dbms/src/Storages/StorageReplicatedMergeTree.cpp
+++ b/dbms/src/Storages/StorageReplicatedMergeTree.cpp
@@ -256,6 +256,8 @@ StorageReplicatedMergeTree::StorageReplicatedMergeTree(
 		database_name + "." + table_name + " (ReplicatedMergeTreeQueue)",
 		data.getDataParts(), current_zookeeper);
 
+	queue.pullLogsToQueue(current_zookeeper, nullptr);
+
 	/// В этом потоке реплика будет активирована.
 	restarting_thread.reset(new ReplicatedMergeTreeRestartingThread(*this));
 }