diff --git a/pkg/volume/csi/nodeinfomanager/nodeinfomanager.go b/pkg/volume/csi/nodeinfomanager/nodeinfomanager.go index ac3a42fe4b3..2ef1da6d9ed 100644 --- a/pkg/volume/csi/nodeinfomanager/nodeinfomanager.go +++ b/pkg/volume/csi/nodeinfomanager/nodeinfomanager.go @@ -417,6 +417,8 @@ func (nim *nodeInfoManager) tryInitializeCSINodeWithAnnotation(csiKubeClient cli // CreateCSINode will set the annotation _, err = nim.CreateCSINode() return err + } else if err != nil { + return err } annotationModified := setMigrationAnnotation(nim.migratedPlugins, nodeInfo)