diff --git a/pkg/kubelet/config/mux.go b/pkg/kubelet/config/mux.go index b2bacff5f38..a2b3e1e0a5f 100644 --- a/pkg/kubelet/config/mux.go +++ b/pkg/kubelet/config/mux.go @@ -21,6 +21,7 @@ import ( "sync" "k8s.io/apimachinery/pkg/util/wait" + "k8s.io/klog/v2" ) type merger interface { @@ -75,6 +76,8 @@ func (m *mux) ChannelWithContext(ctx context.Context, source string) chan interf func (m *mux) listen(source string, listenChannel <-chan interface{}) { for update := range listenChannel { - m.merger.Merge(source, update) + if err := m.merger.Merge(source, update); err != nil { + klog.InfoS("failed merging update", "err", err) + } } }