fix race in SparkMergeTreeWriter::finalizeMerge

apache · Aug 22, 2024 · 4a613f7 · 4a613f7
1 parent ba54da6
commit 4a613f7
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/cpp-ch/local-engine/Storages/Mergetree/SparkMergeTreeWriter.cpp b/cpp-ch/local-engine/Storages/Mergetree/SparkMergeTreeWriter.cpp
@@ -265,11 +265,11 @@ void SparkMergeTreeWriter::finalizeMerge()
                 continue;
 
             GlobalThreadPool::instance().scheduleOrThrow(
-                [&]() -> void
+                [storage_ = storage, tmp = tmp_part]() -> void
                 {
-                    for (const auto & disk : storage->getDisks())
+                    for (const auto & disk : storage_->getDisks())
                     {
-                        auto rel_path = storage->getRelativeDataPath() + "/" + tmp_part;
+                        auto rel_path = storage_->getRelativeDataPath() + "/" + tmp;
                         disk->removeRecursive(rel_path);
                     }
                 });