From 90263476d5c5cb06b8d7d07d545e54771bdd6a53 Mon Sep 17 00:00:00 2001 From: Humble Chirammal Date: Fri, 21 Oct 2016 16:43:07 +0530 Subject: [PATCH] Remove stale volumes if endpoint/svc creation fails. Signed-off-by: Humble Chirammal --- pkg/volume/glusterfs/glusterfs.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/volume/glusterfs/glusterfs.go b/pkg/volume/glusterfs/glusterfs.go index 41bae67b1b1..51d5087e907 100644 --- a/pkg/volume/glusterfs/glusterfs.go +++ b/pkg/volume/glusterfs/glusterfs.go @@ -550,6 +550,10 @@ func (p *glusterfsVolumeProvisioner) CreateVolume() (r *api.GlusterfsVolumeSourc endpoint, service, err := p.createEndpointService(epNamespace, epServiceName, dynamicHostIps, p.options.PVC.Name) if err != nil { glog.Errorf("glusterfs: failed to create endpoint/service") + err = cli.VolumeDelete(volume.Id) + if err != nil { + glog.Errorf("glusterfs: error when deleting the volume :%v , manual deletion required", err) + } return nil, 0, fmt.Errorf("failed to create endpoint/service %v", err) } glog.V(3).Infof("glusterfs: dynamic ep %v and svc : %v ", endpoint, service)