thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-04 21:42:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

This mutex is not necessary

Browse Source
This commit is contained in:
Julia Kartseva 2024-10-04 07:42:40 +00:00
parent 0c9954d977
commit a312477000
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Storages/MergeTree/MergeTreeData.cpp
View File

@ -1783,9 +1783,7 @@ void MergeTreeData::loadDataParts(bool skip_sanity_checks, std::optional<std::un
auto & disk_parts = parts_to_load_by_disk[i]; auto & disk_parts = parts_to_load_by_disk[i];
auto & unexpected_disk_parts = unexpected_parts_to_load_by_disk[i]; auto & unexpected_disk_parts = unexpected_parts_to_load_by_disk[i];
std::mutex loading_mutex; runner([&expected_parts, &unexpected_disk_parts, &disk_parts, this, disk_ptr]()
runner([&expected_parts, &unexpected_disk_parts, &disk_parts, &loading_mutex, this, disk_ptr]()
{ {
for (auto it = disk_ptr->iterateDirectory(relative_data_path); it->isValid(); it->next()) for (auto it = disk_ptr->iterateDirectory(relative_data_path); it->isValid(); it->next())
{ {
@ -1797,7 +1795,6 @@ void MergeTreeData::loadDataParts(bool skip_sanity_checks, std::optional<std::un
if (auto part_info = MergeTreePartInfo::tryParsePartName(it->name(), format_version)) if (auto part_info = MergeTreePartInfo::tryParsePartName(it->name(), format_version))
{ {
std::lock_guard lock(loading_mutex);
if (expected_parts && !expected_parts->contains(it->name())) if (expected_parts && !expected_parts->contains(it->name()))
unexpected_disk_parts.emplace_back(*part_info, it->name(), disk_ptr); unexpected_disk_parts.emplace_back(*part_info, it->name(), disk_ptr);
else else