diff --git a/pkg/kubelet/kuberuntime/kuberuntime_manager.go b/pkg/kubelet/kuberuntime/kuberuntime_manager.go index 814a7b97cce..a64cd463287 100644 --- a/pkg/kubelet/kuberuntime/kuberuntime_manager.go +++ b/pkg/kubelet/kuberuntime/kuberuntime_manager.go @@ -188,7 +188,7 @@ func NewKubeGenericRuntimeManager( logReduction: logreduction.NewLogReduction(identicalErrorDelay), } - typedVersion, err := kubeRuntimeManager.runtimeService.Version(kubeRuntimeAPIVersion) + typedVersion, err := kubeRuntimeManager.getTypedVersion() if err != nil { klog.Errorf("Get runtime version failed: %v", err) return nil, err @@ -253,17 +253,15 @@ func newRuntimeVersion(version string) (*utilversion.Version, error) { func (m *kubeGenericRuntimeManager) getTypedVersion() (*runtimeapi.VersionResponse, error) { typedVersion, err := m.runtimeService.Version(kubeRuntimeAPIVersion) if err != nil { - klog.Errorf("Get remote runtime typed version failed: %v", err) - return nil, err + return nil, fmt.Errorf("get remote runtime typed version failed: %v", err) } return typedVersion, nil } // Version returns the version information of the container runtime. func (m *kubeGenericRuntimeManager) Version() (kubecontainer.Version, error) { - typedVersion, err := m.runtimeService.Version(kubeRuntimeAPIVersion) + typedVersion, err := m.getTypedVersion() if err != nil { - klog.Errorf("Get remote runtime version failed: %v", err) return nil, err }