Skip to content

Commit a318576

Browse files
authored
Merge pull request kubernetes#129589 from neolit123/1.33-remove-etcd-learner-fg
kubeadm: remove the GA EtcdLearnerMode FG
2 parents ccd2b4e + a92297f commit a318576

File tree

2 files changed

+8
-17
lines changed

2 files changed

+8
-17
lines changed

cmd/kubeadm/app/features/features.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -34,8 +34,6 @@ const (
3434
PublicKeysECDSA = "PublicKeysECDSA"
3535
// RootlessControlPlane is expected to be in alpha in v1.22
3636
RootlessControlPlane = "RootlessControlPlane"
37-
// EtcdLearnerMode is expected to be in alpha in v1.27, beta in v1.29, ga in v1.32
38-
EtcdLearnerMode = "EtcdLearnerMode"
3937
// WaitForAllControlPlaneComponents is expected to be alpha in v1.30
4038
WaitForAllControlPlaneComponents = "WaitForAllControlPlaneComponents"
4139
// ControlPlaneKubeletLocalMode is expected to be in alpha in v1.31, beta in v1.32
@@ -55,7 +53,6 @@ var InitFeatureGates = FeatureList{
5553
DeprecationMessage: "Deprecated in favor of the core kubelet feature UserNamespacesSupport which is beta since 1.30." +
5654
" Once UserNamespacesSupport graduates to GA, kubeadm will start using it and RootlessControlPlane will be removed.",
5755
},
58-
EtcdLearnerMode: {FeatureSpec: featuregate.FeatureSpec{Default: true, PreRelease: featuregate.GA, LockToDefault: true}},
5956
WaitForAllControlPlaneComponents: {FeatureSpec: featuregate.FeatureSpec{Default: false, PreRelease: featuregate.Alpha}},
6057
ControlPlaneKubeletLocalMode: {FeatureSpec: featuregate.FeatureSpec{Default: false, PreRelease: featuregate.Alpha}},
6158
NodeLocalCRISocket: {FeatureSpec: featuregate.FeatureSpec{Default: false, PreRelease: featuregate.Alpha}},

cmd/kubeadm/app/phases/etcd/local.go

Lines changed: 8 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -155,11 +155,7 @@ func CreateStackedEtcdStaticPodManifestFile(client clientset.Interface, manifest
155155
return err
156156
}
157157
klog.V(1).Infof("[etcd] Adding etcd member: %s", etcdPeerAddress)
158-
if features.Enabled(cfg.FeatureGates, features.EtcdLearnerMode) {
159-
cluster, err = etcdClient.AddMemberAsLearner(nodeName, etcdPeerAddress)
160-
} else {
161-
cluster, err = etcdClient.AddMember(nodeName, etcdPeerAddress)
162-
}
158+
cluster, err = etcdClient.AddMemberAsLearner(nodeName, etcdPeerAddress)
163159
if err != nil {
164160
return err
165161
}
@@ -178,15 +174,13 @@ func CreateStackedEtcdStaticPodManifestFile(client clientset.Interface, manifest
178174
return nil
179175
}
180176

181-
if features.Enabled(cfg.FeatureGates, features.EtcdLearnerMode) {
182-
learnerID, err := etcdClient.GetMemberID(etcdPeerAddress)
183-
if err != nil {
184-
return err
185-
}
186-
err = etcdClient.MemberPromote(learnerID)
187-
if err != nil {
188-
return err
189-
}
177+
learnerID, err := etcdClient.GetMemberID(etcdPeerAddress)
178+
if err != nil {
179+
return err
180+
}
181+
err = etcdClient.MemberPromote(learnerID)
182+
if err != nil {
183+
return err
190184
}
191185

192186
fmt.Printf("[etcd] Waiting for the new etcd member to join the cluster. This can take up to %v\n", etcdHealthyCheckInterval*etcdHealthyCheckRetries)

0 commit comments

Comments
 (0)