From 752fa093e08924e3e24477b25c81ff06b2e9f056 Mon Sep 17 00:00:00 2001 From: Swati Sehgal Date: Mon, 24 Oct 2022 22:47:02 +0100 Subject: [PATCH] node: devicemgr: GA graduation implies Feature Gate is ON by default Signed-off-by: Swati Sehgal --- cluster/gce/config-default.sh | 6 +----- cluster/gce/config-test.sh | 6 +----- pkg/kubelet/cm/devicemanager/manager.go | 13 ++++--------- 3 files changed, 6 insertions(+), 19 deletions(-) diff --git a/cluster/gce/config-default.sh b/cluster/gce/config-default.sh index aed9c24673e..99564fbad17 100755 --- a/cluster/gce/config-default.sh +++ b/cluster/gce/config-default.sh @@ -256,14 +256,10 @@ if [[ (( "${KUBE_FEATURE_GATES:-}" == *"AllAlpha=true"* ) || ( "${KUBE_FEATURE_G fi # Optional: set feature gates +# shellcheck disable=SC2034 # Variables sourced in other scripts. FEATURE_GATES="${KUBE_FEATURE_GATES:-}" if [[ -n "${NODE_ACCELERATORS}" ]]; then - if [[ -z "${FEATURE_GATES:-}" ]]; then - FEATURE_GATES="DevicePlugins=true" - else - FEATURE_GATES="${FEATURE_GATES},DevicePlugins=true" - fi if [[ "${NODE_ACCELERATORS}" =~ .*type=([a-zA-Z0-9-]+).* ]]; then NON_MASTER_NODE_LABELS="${NON_MASTER_NODE_LABELS},cloud.google.com/gke-accelerator=${BASH_REMATCH[1]}" fi diff --git a/cluster/gce/config-test.sh b/cluster/gce/config-test.sh index 875b69f59e9..24b03d37a66 100755 --- a/cluster/gce/config-test.sh +++ b/cluster/gce/config-test.sh @@ -157,6 +157,7 @@ if [[ (( "${KUBE_FEATURE_GATES:-}" = *"AllAlpha=true"* ) || ( "${KUBE_FEATURE_GA fi # Optional: set feature gates +# shellcheck disable=SC2034 # Variables sourced in other scripts. FEATURE_GATES=${KUBE_FEATURE_GATES:-} #Optional: disable the cloud provider no schedule taint for testing. @@ -305,11 +306,6 @@ if [[ ${KUBE_ENABLE_INSECURE_REGISTRY:-false} = 'true' ]]; then fi if [[ -n "${NODE_ACCELERATORS}" ]]; then - if [[ -z "${FEATURE_GATES:-}" ]]; then - FEATURE_GATES='DevicePlugins=true' - else - FEATURE_GATES="${FEATURE_GATES},DevicePlugins=true" - fi if [[ "${NODE_ACCELERATORS}" =~ .*type=([a-zA-Z0-9-]+).* ]]; then NON_MASTER_NODE_LABELS="${NON_MASTER_NODE_LABELS},cloud.google.com/gke-accelerator=${BASH_REMATCH[1]}" fi diff --git a/pkg/kubelet/cm/devicemanager/manager.go b/pkg/kubelet/cm/devicemanager/manager.go index 7b0283d93e4..73a663ce672 100644 --- a/pkg/kubelet/cm/devicemanager/manager.go +++ b/pkg/kubelet/cm/devicemanager/manager.go @@ -33,9 +33,7 @@ import ( "k8s.io/apimachinery/pkg/api/resource" errorsutil "k8s.io/apimachinery/pkg/util/errors" "k8s.io/apimachinery/pkg/util/sets" - utilfeature "k8s.io/apiserver/pkg/util/feature" pluginapi "k8s.io/kubelet/pkg/apis/deviceplugin/v1beta1" - "k8s.io/kubernetes/pkg/features" "k8s.io/kubernetes/pkg/kubelet/checkpointmanager" "k8s.io/kubernetes/pkg/kubelet/checkpointmanager/errors" "k8s.io/kubernetes/pkg/kubelet/cm/devicemanager/checkpoint" @@ -1005,14 +1003,11 @@ func (m *ManagerImpl) GetDevices(podUID, containerName string) ResourceDeviceIns // depending on whether the node has been recreated. Absence of the checkpoint file strongly indicates the node // has been recreated. func (m *ManagerImpl) ShouldResetExtendedResourceCapacity() bool { - if utilfeature.DefaultFeatureGate.Enabled(features.DevicePlugins) { - checkpoints, err := m.checkpointManager.ListCheckpoints() - if err != nil { - return false - } - return len(checkpoints) == 0 + checkpoints, err := m.checkpointManager.ListCheckpoints() + if err != nil { + return false } - return false + return len(checkpoints) == 0 } func (m *ManagerImpl) setPodPendingAdmission(pod *v1.Pod) {