thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 15:42:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update ReplicatedMergeTreeQueue.cpp

Browse Source
This commit is contained in:
tavplubix 2021-01-25 12:51:06 +03:00 committed by GitHub
parent 963dadae54
commit a88a564aae
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp
View File

@ -302,6 +302,13 @@ void ReplicatedMergeTreeQueue::removeCoveredPartsFromMutations(const String & pa
void ReplicatedMergeTreeQueue::addPartToMutations(const String & part_name) void ReplicatedMergeTreeQueue::addPartToMutations(const String & part_name)
{ {
auto part_info = MergeTreePartInfo::fromPartName(part_name, format_version); auto part_info = MergeTreePartInfo::fromPartName(part_name, format_version);
/// Do not add special virtual parts to parts_to_do
auto max_level = MergeTreePartInfo::MAX_LEVEL; /// DROP/DETACH PARTITION
auto another_max_level = std::numeric_limits<decltype(part_info.level)>::max(); /// REPLACE/MOVE PARTITION
if (part_info.level == max_level || part_info.level == another_max_level)
return;
auto in_partition = mutations_by_partition.find(part_info.partition_id); auto in_partition = mutations_by_partition.find(part_info.partition_id);
if (in_partition == mutations_by_partition.end()) if (in_partition == mutations_by_partition.end())
return; return;
@ -310,11 +317,6 @@ void ReplicatedMergeTreeQueue::addPartToMutations(const String & part_name)
for (auto it = from_it; it != in_partition->second.end(); ++it) for (auto it = from_it; it != in_partition->second.end(); ++it)
{ {
MutationStatus & status = *it->second; MutationStatus & status = *it->second;
/// Do not add special virtual parts to parts_to_do
auto max_level = MergeTreePartInfo::MAX_LEVEL; /// DROP/DETACH PARTITION
auto another_max_level = std::numeric_limits<decltype(part_info.level)>::max(); /// REPLACE/MOVE PARTITION
if (part_info.level == max_level || part_info.level == another_max_level)
continue;
status.parts_to_do.add(part_name); status.parts_to_do.add(part_name);
} }
} }