fix

plugin/healthchecker/leader/checker_leader.go

@@ -482,28 +482,6 @@ const (
 	maxCheckCount     = 3
 )
 
-func (c *LeaderHealthChecker) checkLeaderAlive(ctx context.Context) {
-	ticker := time.NewTicker(time.Second)
-	defer ticker.Stop()
-	for {
-		select {
-		case <-ctx.Done():
-			return
-		case <-ticker.C:
-			peer := c.findLeaderPeer()
-			if peer == nil {
-				// 可能是在 Leader 调整中，不处理探测
-				continue
-			}
-
-			if !peer.IsAlive() {
-				log.Info("[Health Check][Leader] leader peer not alive, do suspend")
-				c.Suspend()
-			}
-		}
-	}
-}
-
 func (c *LeaderHealthChecker) DebugHandlers() []model.DebugHandler {
 	return []model.DebugHandler{
 		{

plugin/healthchecker/leader/peer.go

@@ -289,6 +289,8 @@ func (p *RemotePeer) checkLeaderAlive(ctx context.Context) {
 		select {
 		case <-ctx.Done():
 			ticker.Stop()
+			plog.Info("check leader alive job stop", zap.String("host", p.Host()), zap.Uint32("port", p.port))
+			return
 		case <-ticker.C:
 			var errCount int
 			for i := 0; i < maxCheckCount; i++ {