diff --git a/pkg/controller/persistentvolume/persistentvolume_claim_binder_controller.go b/pkg/controller/persistentvolume/persistentvolume_claim_binder_controller.go index 9d438203342..4b7481f7da7 100644 --- a/pkg/controller/persistentvolume/persistentvolume_claim_binder_controller.go +++ b/pkg/controller/persistentvolume/persistentvolume_claim_binder_controller.go @@ -156,6 +156,7 @@ func (binder *PersistentVolumeClaimBinder) updateClaim(oldObj, newObj interface{ newClaim, ok := newObj.(*api.PersistentVolumeClaim) if !ok { glog.Errorf("Expected PersistentVolumeClaim but handler received %+v", newObj) + return } if err := syncClaim(binder.volumeIndex, binder.client, newClaim); err != nil { glog.Errorf("PVClaimBinder could not update claim %s: %+v", newClaim.Name, err) diff --git a/pkg/controller/persistentvolume/persistentvolume_recycler_controller.go b/pkg/controller/persistentvolume/persistentvolume_recycler_controller.go index cdd08d4f576..e86347ac07f 100644 --- a/pkg/controller/persistentvolume/persistentvolume_recycler_controller.go +++ b/pkg/controller/persistentvolume/persistentvolume_recycler_controller.go @@ -77,6 +77,7 @@ func NewPersistentVolumeRecycler(kubeClient client.Interface, syncPeriod time.Du pv, ok := obj.(*api.PersistentVolume) if !ok { glog.Errorf("Error casting object to PersistentVolume: %v", obj) + return } recycler.reclaimVolume(pv) }, @@ -84,6 +85,7 @@ func NewPersistentVolumeRecycler(kubeClient client.Interface, syncPeriod time.Du pv, ok := newObj.(*api.PersistentVolume) if !ok { glog.Errorf("Error casting object to PersistentVolume: %v", newObj) + return } recycler.reclaimVolume(pv) },