fix

zhannngchen · Sep 2, 2024 · 84d1216 · 84d1216
1 parent 2839a8e
commit 84d1216
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/be/test/olap/segcompaction_mow_test.cpp b/be/test/olap/segcompaction_mow_test.cpp
@@ -76,10 +76,15 @@ class SegCompactionMoWTest : public ::testing::TestWithParam<std::string> {
  options.store_paths = paths;
 
  auto engine = std::make_unique<StorageEngine>(options);
+ Status s = engine->open();
+ EXPECT_TRUE(s.ok()) << s.to_string();
  s_engine = engine.get();
  ExecEnv::GetInstance()->set_storage_engine(std::move(engine));
 
- Status s = s_engine->open();
+ s = ThreadPoolBuilder("SegCompactionTaskThreadPool")
+ .set_min_threads(config::segcompaction_num_threads)
+ .set_max_threads(config::segcompaction_num_threads)
+ .build(&s_engine->_seg_compaction_thread_pool);
  EXPECT_TRUE(s.ok()) << s.to_string();
 
  _data_dir = std::make_unique<DataDir>(*s_engine, lTestDir);