From a4efb6fc130f2116e49be3897ad9e1a9e5a5589e Mon Sep 17 00:00:00 2001 From: SataQiu Date: Fri, 20 Oct 2023 11:01:30 +0800 Subject: [PATCH] kubeadm: add debug log for kubeProxyConfigFromCluster --- cmd/kubeadm/app/componentconfigs/kubeproxy.go | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/cmd/kubeadm/app/componentconfigs/kubeproxy.go b/cmd/kubeadm/app/componentconfigs/kubeproxy.go index d4cfe6ab5bb..5b6fcf1af1c 100644 --- a/cmd/kubeadm/app/componentconfigs/kubeproxy.go +++ b/cmd/kubeadm/app/componentconfigs/kubeproxy.go @@ -17,7 +17,9 @@ limitations under the License. package componentconfigs import ( + "github.com/pkg/errors" clientset "k8s.io/client-go/kubernetes" + "k8s.io/klog/v2" kubeproxyconfig "k8s.io/kube-proxy/config/v1alpha1" netutils "k8s.io/utils/net" @@ -49,7 +51,14 @@ var kubeProxyHandler = handler{ } func kubeProxyConfigFromCluster(h *handler, clientset clientset.Interface, _ *kubeadmapi.ClusterConfiguration) (kubeadmapi.ComponentConfig, error) { - return h.fromConfigMap(clientset, kubeadmconstants.KubeProxyConfigMap, kubeadmconstants.KubeProxyConfigMapKey, false) + configMapName := kubeadmconstants.KubeProxyConfigMap + klog.V(1).Infof("attempting to download the KubeProxyConfiguration from ConfigMap %q", configMapName) + cm, err := h.fromConfigMap(clientset, configMapName, kubeadmconstants.KubeProxyConfigMapKey, false) + if err != nil { + return nil, errors.Wrapf(err, "could not download the kube-proxy configuration from ConfigMap %q", + configMapName) + } + return cm, nil } // kubeProxyConfig implements the kubeadmapi.ComponentConfig interface for kube-proxy