diff --git a/dbms/src/Storages/StorageReplicatedMergeTree.cpp b/dbms/src/Storages/StorageReplicatedMergeTree.cpp index a755e43583d..4928c2c40eb 100644 --- a/dbms/src/Storages/StorageReplicatedMergeTree.cpp +++ b/dbms/src/Storages/StorageReplicatedMergeTree.cpp @@ -1307,6 +1307,10 @@ bool StorageReplicatedMergeTree::queueTask(BackgroundProcessingPool::Context & p else tryLogCurrentException(__PRETTY_FUNCTION__); + /** Это исключение будет записано в элемент очереди, и его можно будет посмотреть с помощью таблицы system.replication_queue. + * Поток, выполняющий это действие, будет спать несколько секунд после исключения. + * См. функцию queue.processEntry. + */ throw; } catch (...)