From 6a283b6bde8786c41fac2f85997c889dfdb84188 Mon Sep 17 00:00:00 2001 From: alesapin Date: Wed, 14 Aug 2019 14:59:45 +0300 Subject: [PATCH] Remove segfault --- dbms/src/Storages/MergeTree/MergeTreeData.cpp | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/dbms/src/Storages/MergeTree/MergeTreeData.cpp b/dbms/src/Storages/MergeTree/MergeTreeData.cpp index ba64ad0a527..1181a6f6393 100644 --- a/dbms/src/Storages/MergeTree/MergeTreeData.cpp +++ b/dbms/src/Storages/MergeTree/MergeTreeData.cpp @@ -785,10 +785,10 @@ void MergeTreeData::loadDataParts(bool skip_sanity_checks) for (size_t i = 0; i < part_names_with_disks.size(); ++i) { - const auto & part_name = part_names_with_disks[i].first; - const auto part_disk_ptr = part_names_with_disks[i].second; - pool.schedule([&] + pool.schedule([&, i] { + const auto & part_name = part_names_with_disks[i].first; + const auto part_disk_ptr = part_names_with_disks[i].second; MergeTreePartInfo part_info; if (!MergeTreePartInfo::tryParsePartName(part_name, &part_info, format_version)) return; @@ -2602,8 +2602,6 @@ void MergeTreeData::movePartitionToSpace(MergeTreeData::DataPartPtr part, DiskSp auto old_active_part = swapActivePart(copied_part); - std::cerr << old_active_part.use_count() << std::endl; - old_active_part->deleteOnDestroy(); }