Skip to content

Commit 49a0c57

Browse files
idebeijerx13n
andauthored
fix: add --leader-elect flags back by reverting #7233 (#7761)
* fix: move leader elect flag binding above InitFlags() * Revert #7233 #7233 broke `--leader-elect` flag by introducing `--lease-resource-name` that is redundant with `--leader-elect-resource-name` * fix: move leader election flag binding above flag parsing which happens in kube_flag.InitFlags() --------- Co-authored-by: Daniel Kłobuszewski <[email protected]>
1 parent bbcb221 commit 49a0c57

File tree

1 file changed

+6
-8
lines changed

1 file changed

+6
-8
lines changed

cluster-autoscaler/main.go

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,6 @@ func multiStringFlag(name string, usage string) *MultiStringFlag {
114114
}
115115

116116
var (
117-
leaseResourceName = flag.String("lease-resource-name", "cluster-autoscaler", "The lease resource to use in leader election.")
118117
clusterName = flag.String("cluster-name", "", "Autoscaled cluster name, if available")
119118
address = flag.String("address", ":8085", "The address to expose prometheus metrics.")
120119
kubernetes = flag.String("kubernetes", "", "Kubernetes master location. Leave blank for default")
@@ -699,6 +698,9 @@ func main() {
699698
klog.Fatalf("Failed to add logging feature flags: %v", err)
700699
}
701700

701+
leaderElection := leaderElectionConfiguration()
702+
componentopts.BindLeaderElectionFlags(&leaderElection, pflag.CommandLine)
703+
702704
logsapi.AddFlags(loggingConfig, pflag.CommandLine)
703705
featureGate.AddFlag(pflag.CommandLine)
704706
kube_flag.InitFlags()
@@ -712,10 +714,6 @@ func main() {
712714
}
713715
}
714716

715-
leaderElection := defaultLeaderElectionConfiguration()
716-
leaderElection.LeaderElect = true
717-
componentopts.BindLeaderElectionFlags(&leaderElection, pflag.CommandLine)
718-
719717
logs.InitLogs()
720718
if err := logsapi.ValidateAndApply(loggingConfig, featureGate); err != nil {
721719
klog.Fatalf("Failed to validate and apply logging configuration: %v", err)
@@ -795,14 +793,14 @@ func main() {
795793
}
796794
}
797795

798-
func defaultLeaderElectionConfiguration() componentbaseconfig.LeaderElectionConfiguration {
796+
func leaderElectionConfiguration() componentbaseconfig.LeaderElectionConfiguration {
799797
return componentbaseconfig.LeaderElectionConfiguration{
800-
LeaderElect: false,
798+
LeaderElect: true,
801799
LeaseDuration: metav1.Duration{Duration: defaultLeaseDuration},
802800
RenewDeadline: metav1.Duration{Duration: defaultRenewDeadline},
803801
RetryPeriod: metav1.Duration{Duration: defaultRetryPeriod},
804802
ResourceLock: resourcelock.LeasesResourceLock,
805-
ResourceName: *leaseResourceName,
803+
ResourceName: "cluster-autoscaler",
806804
}
807805
}
808806

0 commit comments

Comments
 (0)