fixed (ClickHouse#243)

bigo-sg · Dec 26, 2022 · 5ab0b59 · 5ab0b59
1 parent 11ecd0e
commit 5ab0b59
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/utils/local-engine/Storages/StorageMergeTreeFactory.cpp b/utils/local-engine/Storages/StorageMergeTreeFactory.cpp
@@ -13,9 +13,9 @@ CustomStorageMergeTreePtr
 StorageMergeTreeFactory::getStorage(StorageID id, ColumnsDescription columns, std::function<CustomStorageMergeTreePtr()> creator)
 {
     auto table_name = id.database_name + "." + id.table_name;
+    std::lock_guard lock(storage_map_mutex);
     if (!storage_map.contains(table_name))
     {
-        std::lock_guard lock(storage_map_mutex);
         if (storage_map.contains(table_name))
         {
             std::set<std::string> existed_columns = storage_columns_map.at(table_name);
@@ -45,9 +45,9 @@ StorageInMemoryMetadataPtr StorageMergeTreeFactory::getMetadata(StorageID id, st
 {
     auto table_name = id.database_name + "." + id.table_name;
 
+    std::lock_guard lock(metadata_map_mutex);
     if (!metadata_map.contains(table_name))
     {
-        std::lock_guard lock(metadata_map_mutex);
         if (!metadata_map.contains(table_name))
         {
             metadata_map.emplace(table_name, creator());