From 0d2460281dd3c887ede7ab34775f874ee850b539 Mon Sep 17 00:00:00 2001 From: lance6716 Date: Tue, 16 Nov 2021 16:25:09 +0800 Subject: [PATCH] fix fmt --- dm/dm/master/scheduler/scheduler.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/dm/dm/master/scheduler/scheduler.go b/dm/dm/master/scheduler/scheduler.go index c04ccf836b3..7b7dcb2557a 100644 --- a/dm/dm/master/scheduler/scheduler.go +++ b/dm/dm/master/scheduler/scheduler.go @@ -1785,9 +1785,9 @@ func (s *Scheduler) handleWorkerOnline(ev ha.WorkerEvent, toLock bool) error { // of course nothing, so we find the relay source from a better place for source, workerM := range s.relayWorkers { if _, ok2 := workerM[w.BaseInfo().Name]; ok2 { - lastRelaySource = source - break - } + lastRelaySource = source + break + } } } w.ToFree()