From 77d551788ab505c512fe495d054cbcce0582b093 Mon Sep 17 00:00:00 2001 From: serxa Date: Thu, 8 Dec 2022 00:40:43 +0000 Subject: [PATCH] Fix relaxed "too many parts" threshold --- src/Storages/MergeTree/MergeTreeData.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/Storages/MergeTree/MergeTreeData.cpp b/src/Storages/MergeTree/MergeTreeData.cpp index d2b1da9abf8..2ae8a4437dc 100644 --- a/src/Storages/MergeTree/MergeTreeData.cpp +++ b/src/Storages/MergeTree/MergeTreeData.cpp @@ -3675,13 +3675,13 @@ void MergeTreeData::delayInsertOrThrowIfNeeded(Poco::Event * until, ContextPtr q parts_count_in_partition, ReadableSize(average_part_size)); } - if (k_inactive < 0 && parts_count_in_partition < parts_to_delay_insert) + if (k_inactive < 0 && (parts_count_in_partition < parts_to_delay_insert || parts_are_large_enough_in_average)) return; const ssize_t k_active = ssize_t(parts_count_in_partition) - ssize_t(parts_to_delay_insert); size_t max_k; size_t k; - if (k_active > k_inactive && !parts_are_large_enough_in_average) + if (k_active > k_inactive) { max_k = parts_to_throw_insert - parts_to_delay_insert; k = k_active + 1;