From c562505b19071ad92c1df39cc15c07dc1cf247ca Mon Sep 17 00:00:00 2001 From: lhy1024 Date: Fri, 8 Nov 2024 14:26:52 +0800 Subject: [PATCH] cluster: avoid unexpect scheduling job start Signed-off-by: lhy1024 --- server/cluster/cluster.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/server/cluster/cluster.go b/server/cluster/cluster.go index 9d6f51b48e7..f10ffb88739 100644 --- a/server/cluster/cluster.go +++ b/server/cluster/cluster.go @@ -459,7 +459,13 @@ func (c *RaftCluster) runServiceCheckJob() { log.Info("service check job is stopped") return case <-schedulingTicker.C: - c.checkSchedulingService() + // ensure raft cluster is running + // avoid unexpected startSchedulingJobs when raft cluster is stopping + c.RLock() + if c.running { + c.checkSchedulingService() + } + c.RUnlock() case <-tsoTicker.C: // ensure raft cluster is running // avoid unexpected startTSOJobsIfNeeded when raft cluster is stopping