Skip to content

Commit

Permalink
fix(storage): typo
Browse files Browse the repository at this point in the history
  • Loading branch information
Li0k committed Apr 2, 2024
1 parent 4c57200 commit 07abd7b
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions src/meta/src/hummock/manager/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -953,7 +953,7 @@ impl HummockManager {
// compaction group has been deleted.
return Ok(None);
}

let _timer = start_measure_real_process_timer!(self);
let can_trivial_move = matches!(selector.task_type(), compact_task::TaskType::Dynamic)
|| matches!(selector.task_type(), compact_task::TaskType::Emergency);

Expand Down Expand Up @@ -1245,13 +1245,11 @@ impl HummockManager {
Ok(())
}

#[named]
pub async fn get_compact_task(
&self,
compaction_group_id: CompactionGroupId,
selector: &mut Box<dyn CompactionSelector>,
) -> Result<Option<CompactTask>> {
let _timer = start_measure_real_process_timer!(self);
fail_point!("fp_get_compact_task", |_| Err(Error::MetaStore(
anyhow::anyhow!("failpoint metastore error")
)));
Expand Down Expand Up @@ -1326,7 +1324,6 @@ impl HummockManager {
table_stats_change: Option<PbTableStatsMap>,
) -> Result<bool> {
let mut guard = write_lock!(self, compaction).await;
let _timer = start_measure_real_process_timer!(self);
self.report_compact_task_impl(
task_id,
None,
Expand Down Expand Up @@ -1394,6 +1391,8 @@ impl HummockManager {
{
// The compaction task is finished.
let mut versioning_guard = write_lock!(self, versioning).await;
let _timer = start_measure_real_process_timer!(self);

let versioning = versioning_guard.deref_mut();
let mut current_version = versioning.current_version.clone();
// purge stale compact_status
Expand Down

0 comments on commit 07abd7b

Please sign in to comment.