This commit is contained in:
alesapin 2022-02-10 22:50:15 +03:00
parent ef61c9b47c
commit 705529ca03

View File

@ -160,7 +160,7 @@ std::pair<bool, ReplicatedMergeMutateTaskBase::PartLogWriter> MergeFromLogEntryT
if (auto disk = reserved_space->getDisk(); disk->getType() == DB::DiskType::S3)
{
String dummy;
if (!storage.findReplicaHavingCoveringPart(entry.new_part_name, true).empty())
if (!storage.findReplicaHavingCoveringPart(entry.new_part_name, true, dummy).empty())
{
LOG_DEBUG(log, "Merge of part {} finished by some other replica, will fetch merged part", entry.new_part_name);
return {false, {}};