diff --git a/src/Storages/MergeTree/MergeTreePartInfo.cpp b/src/Storages/MergeTree/MergeTreePartInfo.cpp index 8d7b06ca15c..61e3d00b03c 100644 --- a/src/Storages/MergeTree/MergeTreePartInfo.cpp +++ b/src/Storages/MergeTree/MergeTreePartInfo.cpp @@ -315,7 +315,7 @@ bool MergeTreePartInfo::areAllBlockNumbersCovered(const MergeTreePartInfo & bloc for (const auto & candidate : candidates) { - if (candidate.min_block - current_right_block > 1) + if (current_right_block + 1 != candidate.min_block) return false; current_right_block = candidate.max_block;