fix ut

Signed-off-by: edwinhzhang <[email protected]>
StarRocks · Oct 19, 2024 · a6030c4 · a6030c4
1 parent ff9d4e5
commit a6030c4
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/be/src/storage/compaction_manager.h b/be/src/storage/compaction_manager.h
@@ -42,10 +42,6 @@ class CompactionManager {
 
  void stop();
 
- int32_t max_task_num() {
- std::lock_guard lg(_tasks_mutex);
- return _max_task_num;
- }
 
  size_t candidates_size() {
  std::lock_guard lg(_candidates_mutex);
@@ -97,7 +93,10 @@ class CompactionManager {
  return exceed;
  }
 
- int32_t max_task_num() { return _max_task_num; }
+ int32_t max_task_num() {
+ std::lock_guard lg(_tasks_mutex);
+ return _max_task_num;
+ }
 
  uint16_t running_cumulative_tasks_num_for_dir(DataDir* data_dir) {
  std::lock_guard lg(_tasks_mutex);