thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-10 01:25:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Antonio Andelic 2024-02-20 14:35:19 +01:00
parent cfda64e1a4
commit 11f3b06099
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Coordination/Changelog.cpp
View File

@ -68,9 +68,13 @@ void moveFileBetweenDisks(DiskPtr disk_from, ChangelogFileDescriptionPtr descrip
/// a different thread could be trying to read from the file
/// we should make sure the source disk contains the file while read is in progress
description->withLock([&]{ description->disk = disk_to; });
disk_from->removeFile(description->path);
description->withLock(
[&]
{
description->disk = disk_to;
description->path = path_to;
});
disk_from->removeFile(description->path);
}
constexpr auto DEFAULT_PREFIX = "changelog";