This commit is contained in:
Evgeniy Gatov 2016-01-18 19:49:44 +03:00
commit e10cfb40b4

View File

@ -1392,8 +1392,6 @@ void StorageReplicatedMergeTree::mergeSelectingThread()
try
{
std::lock_guard<std::mutex> merge_selecting_lock(merge_selecting_mutex);
if (need_pull)
{
/// Нужно загрузить новые записи в очередь перед тем, как выбирать куски для слияния.
@ -1402,6 +1400,8 @@ void StorageReplicatedMergeTree::mergeSelectingThread()
need_pull = false;
}
std::lock_guard<std::mutex> merge_selecting_lock(merge_selecting_mutex);
/** Сколько в очереди или в фоновом потоке мерджей крупных кусков.
* Если их больше половины от размера пула потоков для мерджа, то можно мерджить только мелкие куски.
*/