diff --git a/pkg/mcs/resourcemanager/server/server.go b/pkg/mcs/resourcemanager/server/server.go index dbc60ef9489..47248208c8a 100644 --- a/pkg/mcs/resourcemanager/server/server.go +++ b/pkg/mcs/resourcemanager/server/server.go @@ -387,7 +387,7 @@ func CreateServerWrapper(cmd *cobra.Command, args []string) { defer log.Sync() versioninfo.Log(serviceName) - log.Info("Resource manager config", zap.Reflect("config", cfg)) + log.Info("resource manager config", zap.Reflect("config", cfg)) grpcprometheus.EnableHandlingTimeHistogram() metricutil.Push(&cfg.Metric) diff --git a/pkg/mcs/scheduling/server/server.go b/pkg/mcs/scheduling/server/server.go index 81bff8b7f6b..32788284b70 100644 --- a/pkg/mcs/scheduling/server/server.go +++ b/pkg/mcs/scheduling/server/server.go @@ -540,7 +540,7 @@ func CreateServerWrapper(cmd *cobra.Command, args []string) { defer log.Sync() versioninfo.Log(serviceName) - log.Info("Scheduling service config", zap.Reflect("config", cfg)) + log.Info("scheduling service config", zap.Reflect("config", cfg)) grpcprometheus.EnableHandlingTimeHistogram() metricutil.Push(&cfg.Metric) diff --git a/pkg/schedule/coordinator.go b/pkg/schedule/coordinator.go index 8cd5567b75c..bcbef0a1a08 100644 --- a/pkg/schedule/coordinator.go +++ b/pkg/schedule/coordinator.go @@ -144,7 +144,7 @@ func (c *Coordinator) PatrolRegions() { ticker := time.NewTicker(c.cluster.GetCheckerConfig().GetPatrolRegionInterval()) defer ticker.Stop() - log.Info("Coordinator starts patrol regions") + log.Info("coordinator starts patrol regions") start := time.Now() var ( key []byte @@ -252,7 +252,7 @@ func (c *Coordinator) checkPriorityRegions() { func (c *Coordinator) checkSuspectRanges() { defer logutil.LogPanic() defer c.wg.Done() - log.Info("Coordinator begins to check suspect key ranges") + log.Info("coordinator begins to check suspect key ranges") ticker := time.NewTicker(checkSuspectRangesInterval) defer ticker.Stop() for { @@ -316,7 +316,7 @@ func (c *Coordinator) drivePushOperator() { defer logutil.LogPanic() defer c.wg.Done() - log.Info("Coordinator begins to actively drive push operator") + log.Info("coordinator begins to actively drive push operator") ticker := time.NewTicker(pushOperatorTickInterval) defer ticker.Stop() for { @@ -370,10 +370,10 @@ func (c *Coordinator) driveSlowNodeScheduler() { func (c *Coordinator) RunUntilStop() { c.Run() <-c.ctx.Done() - log.Info("Coordinator is stopping") + log.Info("coordinator is stopping") c.GetSchedulersController().Wait() c.wg.Wait() - log.Info("Coordinator has been stopped") + log.Info("coordinator has been stopped") } // Run starts coordinator. @@ -383,20 +383,20 @@ func (c *Coordinator) Run() { ticker = time.NewTicker(100 * time.Millisecond) }) defer ticker.Stop() - log.Info("Coordinator starts to collect cluster information") + log.Info("coordinator starts to collect cluster information") for { if c.ShouldRun() { - log.Info("Coordinator has finished cluster information preparation") + log.Info("coordinator has finished cluster information preparation") break } select { case <-ticker.C: case <-c.ctx.Done(): - log.Info("Coordinator stops running") + log.Info("coordinator stops running") return } } - log.Info("Coordinator starts to run schedulers") + log.Info("coordinator starts to run schedulers") c.InitSchedulers(true) c.wg.Add(4) diff --git a/pkg/unsaferecovery/unsafe_recovery_controller.go b/pkg/unsaferecovery/unsafe_recovery_controller.go index 110b7277d9e..aa45ba6a2bd 100644 --- a/pkg/unsaferecovery/unsafe_recovery_controller.go +++ b/pkg/unsaferecovery/unsafe_recovery_controller.go @@ -465,7 +465,7 @@ func (u *Controller) CollectReport(heartbeat *pdpb.StoreHeartbeatRequest) (bool, } if heartbeat.StoreReport.GetStep() != u.step { - log.Info("Unsafe recovery receives invalid store report", + log.Info("unsafe recovery receives invalid store report", zap.Uint64("store-id", storeID), zap.Uint64("expected-step", u.step), zap.Uint64("obtained-step", heartbeat.StoreReport.GetStep())) // invalid store report, ignore return false, nil @@ -891,7 +891,7 @@ func (t *regionTree) insert(item *regionItem) (bool, error) { } for _, newer := range overlaps { - log.Info("Unsafe recovery found overlap regions", logutil.ZapRedactStringer("newer-region-meta", core.RegionToHexMeta(newer.Region())), logutil.ZapRedactStringer("older-region-meta", core.RegionToHexMeta(item.Region()))) + log.Info("unsafe recovery found overlap regions", logutil.ZapRedactStringer("newer-region-meta", core.RegionToHexMeta(newer.Region())), logutil.ZapRedactStringer("older-region-meta", core.RegionToHexMeta(item.Region()))) // it's ensured by the `buildUpFromReports` that peers are inserted in epoch descending order. if newer.IsEpochStale(item) { return false, errors.Errorf("region %v's epoch shouldn't be staler than old ones %v", item, newer)