From 3633ea23d32da9dfa4119ab7774313a3ea3e062c Mon Sep 17 00:00:00 2001 From: Keisuke Ishigami Date: Tue, 15 Jul 2025 01:07:25 +0900 Subject: [PATCH] chore Kubernetes-commit: 09ec6f744833fb72a319013ae25cf0286cdd125e --- tools/leaderelection/leaderelection.go | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/tools/leaderelection/leaderelection.go b/tools/leaderelection/leaderelection.go index 35afc372..f7d9f882 100644 --- a/tools/leaderelection/leaderelection.go +++ b/tools/leaderelection/leaderelection.go @@ -308,8 +308,8 @@ func (le *LeaderElector) renew(ctx context.Context) { func (le *LeaderElector) release() bool { ctx := context.Background() - // 1. obtain the electionRecord - oldLeaderElectionRecord, oldLeaderElectionRawRecord, err := le.config.Lock.Get(ctx) + // update the resourceVersion of lease + oldLeaderElectionRecord, _, err := le.config.Lock.Get(ctx) if err != nil { if !errors.IsNotFound(err) { klog.Errorf("error retrieving resource lock %v: %v", le.config.Lock.Describe(), err) @@ -318,12 +318,6 @@ func (le *LeaderElector) release() bool { klog.Infof("lease lock not found: %v", le.config.Lock.Describe()) return false } - // 2. Record obtained, check the Identity & Time - if !bytes.Equal(le.observedRawRecord, oldLeaderElectionRawRecord) { - le.setObservedRecord(oldLeaderElectionRecord) - - le.observedRawRecord = oldLeaderElectionRawRecord - } if !le.IsLeader() { return true