diff --git a/internal/util/sessionutil/session_util.go b/internal/util/sessionutil/session_util.go index a55ecc9923..8b1796d2db 100644 --- a/internal/util/sessionutil/session_util.go +++ b/internal/util/sessionutil/session_util.go @@ -784,6 +784,7 @@ func (s *Session) LivenessCheck(ctx context.Context, callback func()) { return case <-ctx.Done(): log.Debug("liveness exits due to context done") + s.enableRetryKeepAlive = false // cancel the etcd keepAlive context if s.keepAliveCancel != nil { s.keepAliveCancel()