From a1335cba688d15cafa173c109fa553a26c71e423 Mon Sep 17 00:00:00 2001 From: c00522440 Date: Fri, 16 Apr 2021 16:57:57 +0800 Subject: [PATCH] del duplicate import --- cmd/kube-apiserver/app/aggregator.go | 6 ++---- cmd/kube-apiserver/app/server.go | 3 +-- 2 files changed, 3 insertions(+), 6 deletions(-) diff --git a/cmd/kube-apiserver/app/aggregator.go b/cmd/kube-apiserver/app/aggregator.go index 457cefd027c..77d9f69d6be 100644 --- a/cmd/kube-apiserver/app/aggregator.go +++ b/cmd/kube-apiserver/app/aggregator.go @@ -33,12 +33,10 @@ import ( "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apiserver/pkg/admission" - "k8s.io/apiserver/pkg/features" genericfeatures "k8s.io/apiserver/pkg/features" genericapiserver "k8s.io/apiserver/pkg/server" "k8s.io/apiserver/pkg/server/healthz" genericoptions "k8s.io/apiserver/pkg/server/options" - "k8s.io/apiserver/pkg/util/feature" utilfeature "k8s.io/apiserver/pkg/util/feature" kubeexternalinformers "k8s.io/client-go/informers" "k8s.io/client-go/tools/cache" @@ -82,7 +80,7 @@ func createAggregatorConfig( &genericConfig, externalInformers, genericConfig.LoopbackClientConfig, - feature.DefaultFeatureGate, + utilfeature.DefaultFeatureGate, pluginInitializers...) if err != nil { return nil, err @@ -90,7 +88,7 @@ func createAggregatorConfig( // copy the etcd options so we don't mutate originals. etcdOptions := *commandOptions.Etcd - etcdOptions.StorageConfig.Paging = utilfeature.DefaultFeatureGate.Enabled(features.APIListChunking) + etcdOptions.StorageConfig.Paging = utilfeature.DefaultFeatureGate.Enabled(genericfeatures.APIListChunking) etcdOptions.StorageConfig.Codec = aggregatorscheme.Codecs.LegacyCodec(v1.SchemeGroupVersion, v1beta1.SchemeGroupVersion) etcdOptions.StorageConfig.EncodeVersioner = runtime.NewMultiGroupVersioner(v1.SchemeGroupVersion, schema.GroupKind{Group: v1beta1.GroupName}) genericConfig.RESTOptionsGetter = &genericoptions.SimpleRestOptionsFactory{Options: etcdOptions} diff --git a/cmd/kube-apiserver/app/server.go b/cmd/kube-apiserver/app/server.go index 59413c4be1d..72e983b83db 100644 --- a/cmd/kube-apiserver/app/server.go +++ b/cmd/kube-apiserver/app/server.go @@ -48,7 +48,6 @@ import ( serveroptions "k8s.io/apiserver/pkg/server/options" serverstorage "k8s.io/apiserver/pkg/server/storage" "k8s.io/apiserver/pkg/storage/etcd3/preflight" - "k8s.io/apiserver/pkg/util/feature" utilfeature "k8s.io/apiserver/pkg/util/feature" utilflowcontrol "k8s.io/apiserver/pkg/util/flowcontrol" "k8s.io/apiserver/pkg/util/webhook" @@ -551,7 +550,7 @@ func buildGenericConfig( genericConfig, versionedInformers, kubeClientConfig, - feature.DefaultFeatureGate, + utilfeature.DefaultFeatureGate, pluginInitializers...) if err != nil { lastErr = fmt.Errorf("failed to initialize admission: %v", err)