fix: atomic

pingcap · Jan 11, 2022 · 9d6f538 · 9d6f538
1 parent 8e627ef
commit 9d6f538
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dm/dm/master/scheduler/scheduler.go b/dm/dm/master/scheduler/scheduler.go
@@ -343,7 +343,7 @@ func (s *Scheduler) AddSourceCfgWithWorker(cfg *config.SourceConfig, workerName
 	s.mu.Lock()
 	defer s.mu.Unlock()
 
-	if !s.started {
+	if !s.started.Load() {
 		return terror.ErrSchedulerNotStarted.Generate()
 	}