This commit is contained in:
Alexander Tokmakov 2023-02-01 14:47:57 +01:00
parent 7862990721
commit aba4a00a17

View File

@ -104,6 +104,8 @@ bool ReplicatedMergeTreeQueue::isGoingToBeDropped(const MergeTreePartInfo & part
bool ReplicatedMergeTreeQueue::isGoingToBeDroppedImpl(const MergeTreePartInfo & part_info, MergeTreePartInfo * out_drop_range_info) const
{
String covering_virtual = virtual_parts.getContainingPart(part_info);
if (!covering_virtual.empty())
{
auto covering_virtual_info = MergeTreePartInfo::fromPartName(covering_virtual, format_version);
if (covering_virtual_info.isFakeDropRangePart())
{
@ -111,6 +113,7 @@ bool ReplicatedMergeTreeQueue::isGoingToBeDroppedImpl(const MergeTreePartInfo &
*out_drop_range_info = covering_virtual_info;
return true;
}
}
return drop_parts.hasDropPart(part_info, out_drop_range_info);
}