diff --git a/pkg/kubelet/pluginmanager/plugin_manager.go b/pkg/kubelet/pluginmanager/plugin_manager.go index 79e0c8c46b7..e1491165feb 100644 --- a/pkg/kubelet/pluginmanager/plugin_manager.go +++ b/pkg/kubelet/pluginmanager/plugin_manager.go @@ -108,7 +108,11 @@ var _ PluginManager = &pluginManager{} func (pm *pluginManager) Run(sourcesReady config.SourcesReady, stopCh <-chan struct{}) { defer runtime.HandleCrash() - pm.desiredStateOfWorldPopulator.Start(stopCh) + if err := pm.desiredStateOfWorldPopulator.Start(stopCh); err != nil { + klog.ErrorS(err, "The desired_state_of_world populator (plugin watcher) starts failed!") + return + } + klog.V(2).InfoS("The desired_state_of_world populator (plugin watcher) starts") klog.InfoS("Starting Kubelet Plugin Manager")