From 25036fec3112edf8f0aae44aa9248651879a76bc Mon Sep 17 00:00:00 2001 From: Alexey Milovidov Date: Mon, 18 Jan 2016 19:27:27 +0300 Subject: [PATCH] dbms: addition [#METR-19586]. --- dbms/src/Storages/StorageReplicatedMergeTree.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dbms/src/Storages/StorageReplicatedMergeTree.cpp b/dbms/src/Storages/StorageReplicatedMergeTree.cpp index e074af24909..9c1de98ffdb 100644 --- a/dbms/src/Storages/StorageReplicatedMergeTree.cpp +++ b/dbms/src/Storages/StorageReplicatedMergeTree.cpp @@ -1353,8 +1353,6 @@ void StorageReplicatedMergeTree::mergeSelectingThread() try { - std::lock_guard merge_selecting_lock(merge_selecting_mutex); - if (need_pull) { /// Нужно загрузить новые записи в очередь перед тем, как выбирать куски для слияния. @@ -1363,6 +1361,8 @@ void StorageReplicatedMergeTree::mergeSelectingThread() need_pull = false; } + std::lock_guard merge_selecting_lock(merge_selecting_mutex); + /** Сколько в очереди или в фоновом потоке мерджей крупных кусков. * Если их больше половины от размера пула потоков для мерджа, то можно мерджить только мелкие куски. */