diff --git a/test/e2e_node/e2e_node_suite_test.go b/test/e2e_node/e2e_node_suite_test.go index 77163b29fe5..3cacbe1f54f 100644 --- a/test/e2e_node/e2e_node_suite_test.go +++ b/test/e2e_node/e2e_node_suite_test.go @@ -130,6 +130,12 @@ func TestMain(m *testing.M) { fmt.Fprintf(os.Stderr, "ERROR: initialize feature gates: %v", err) os.Exit(1) } + + if err := services.SetFeatureGatesForInProcessComponents(featureGates); err != nil { + fmt.Fprintf(os.Stderr, "ERROR: initialize process feature gates: %v", err) + os.Exit(1) + } + setExtraEnvs() os.Exit(m.Run()) } diff --git a/test/e2e_node/services/internal_services.go b/test/e2e_node/services/internal_services.go index c9d80058b9f..06e50ec9b2f 100644 --- a/test/e2e_node/services/internal_services.go +++ b/test/e2e_node/services/internal_services.go @@ -23,6 +23,7 @@ import ( etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing" "k8s.io/apiserver/pkg/storage/storagebackend" + utilfeature "k8s.io/apiserver/pkg/util/feature" "k8s.io/klog/v2/ktesting" "k8s.io/kubernetes/test/e2e/framework" @@ -139,3 +140,7 @@ func getServicesHealthCheckURLs() []string { getAPIServerHealthCheckURL(), } } + +func SetFeatureGatesForInProcessComponents(featureGates map[string]bool) error { + return utilfeature.DefaultMutableFeatureGate.SetFromMap(featureGates) +}