This commit is contained in:
alesapin 2022-02-10 22:49:33 +03:00
parent 3af06b23f8
commit ef61c9b47c

View File

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