Skip to content

Commit

Permalink
fix log message
Browse files Browse the repository at this point in the history
  • Loading branch information
kolesnikovae committed Feb 5, 2025
1 parent 0234998 commit 32d96ed
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions pkg/experiment/metastore/compaction_raft_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,6 @@ func (h *CompactionCommandHandler) GetCompactionPlanUpdate(
}
if job != nil {
p.AssignedJobs = append(p.AssignedJobs, job)
continue
}
}

Expand All @@ -129,7 +128,7 @@ func (h *CompactionCommandHandler) GetCompactionPlanUpdate(
// is when the scheduler queue is full; theoretically, this should
// not happen, because we evicted jobs before creating new ones.
// However, if all the jobs are healthy, we may end up here.
level.Warn(h.logger).Log("msg", "failed to create compaction job", "err", err)
level.Warn(h.logger).Log("msg", "compaction job rejected by scheduler")
break
}
p.NewJobs = append(p.NewJobs, &raft_log.NewCompactionJob{
Expand Down

0 comments on commit 32d96ed

Please sign in to comment.