From dd767cdcd6752c4f6a4fac85cf0b5ef17877ac6e Mon Sep 17 00:00:00 2001 From: KunWuLuan Date: Thu, 21 Aug 2025 09:27:11 +0800 Subject: [PATCH] add err check when plugin init --- pkg/scheduler/framework/plugins/nodevolumelimits/csi.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/pkg/scheduler/framework/plugins/nodevolumelimits/csi.go b/pkg/scheduler/framework/plugins/nodevolumelimits/csi.go index ab7129504a1..055bece343c 100644 --- a/pkg/scheduler/framework/plugins/nodevolumelimits/csi.go +++ b/pkg/scheduler/framework/plugins/nodevolumelimits/csi.go @@ -592,13 +592,15 @@ func NewCSI(_ context.Context, _ runtime.Object, handle fwk.Handle, fts feature. vaLister := informerFactory.Storage().V1().VolumeAttachments().Lister() csiDriverLister := informerFactory.Storage().V1().CSIDrivers().Lister() vaindexer := informerFactory.Storage().V1().VolumeAttachments().Informer().GetIndexer() - informerFactory.Storage().V1().VolumeAttachments().Informer().AddIndexers(cache.Indexers{"nodename": func(obj interface{}) ([]string, error) { + if err := informerFactory.Storage().V1().VolumeAttachments().Informer().AddIndexers(cache.Indexers{"nodename": func(obj interface{}) ([]string, error) { va, ok := obj.(*storagev1.VolumeAttachment) if !ok { return []string{}, nil } return []string{va.Spec.NodeName}, nil - }}) + }}); err != nil { + return nil, fmt.Errorf("failed to add index to VA informer: %w", err) + } csiTranslator := csitrans.New() return &CSILimits{