Fix slow test data race

infiniflow · Jan 3, 2025 · f79eca1 · f79eca1
1 parent 9e0b6cc
commit f79eca1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/storage/invertedindex/memory_indexer.cpp b/src/storage/invertedindex/memory_indexer.cpp
@@ -281,6 +281,7 @@ void MemoryIndexer::Dump(bool offline, bool spill) {
     while (GetInflightTasks() > 0) {
         CommitSync(100);
     }
+    std::unique_lock lock(mutex_commit_);
 
     String posting_file = Path(index_dir_) / (base_name_ + POSTING_SUFFIX + (spill ? SPILL_SUFFIX : ""));
     String dict_file = Path(index_dir_) / (base_name_ + DICT_SUFFIX + (spill ? SPILL_SUFFIX : ""));