diff --git a/pkg/volume/util/operationexecutor/operation_generator.go b/pkg/volume/util/operationexecutor/operation_generator.go index a084bedde4b..22917267510 100644 --- a/pkg/volume/util/operationexecutor/operation_generator.go +++ b/pkg/volume/util/operationexecutor/operation_generator.go @@ -1564,14 +1564,6 @@ func (og *operationGenerator) GenerateVerifyControllerAttachedVolumeFunc( return volumetypes.NewOperationContext(eventErr, detailedErr, migrated) } - if node == nil { - // On failure, return error. Caller will log and retry. - eventErr, detailedErr := volumeToMount.GenerateError( - "VerifyControllerAttachedVolume failed", - fmt.Errorf("node object retrieved from API server is nil")) - return volumetypes.NewOperationContext(eventErr, detailedErr, migrated) - } - for _, attachedVolume := range node.Status.VolumesAttached { if attachedVolume.Name == volumeToMount.VolumeName { addVolumeNodeErr := actualStateOfWorld.MarkVolumeAsAttached( @@ -1615,13 +1607,6 @@ func (og *operationGenerator) verifyVolumeIsSafeToDetach( return volumeToDetach.GenerateErrorDetailed("DetachVolume failed fetching node from API server", fetchErr) } - if node == nil { - // On failure, return error. Caller will log and retry. - return volumeToDetach.GenerateErrorDetailed( - "DetachVolume failed fetching node from API server", - fmt.Errorf("node object retrieved from API server is nil")) - } - for _, inUseVolume := range node.Status.VolumesInUse { if inUseVolume == volumeToDetach.VolumeName { return volumeToDetach.GenerateErrorDetailed(