From 32d96eddcad6f07a8a18efd75ff74340d36f429e Mon Sep 17 00:00:00 2001 From: Anton Kolesnikov Date: Wed, 5 Feb 2025 20:04:18 +0800 Subject: [PATCH] fix log message --- pkg/experiment/metastore/compaction_raft_handler.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/pkg/experiment/metastore/compaction_raft_handler.go b/pkg/experiment/metastore/compaction_raft_handler.go index 487d275fd7..5fb52ec0cd 100644 --- a/pkg/experiment/metastore/compaction_raft_handler.go +++ b/pkg/experiment/metastore/compaction_raft_handler.go @@ -102,7 +102,6 @@ func (h *CompactionCommandHandler) GetCompactionPlanUpdate( } if job != nil { p.AssignedJobs = append(p.AssignedJobs, job) - continue } } @@ -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{