diff --git a/pkg/volume/flexvolume/mounter.go b/pkg/volume/flexvolume/mounter.go index 94b2ffd748..5085293cc1 100644 --- a/pkg/volume/flexvolume/mounter.go +++ b/pkg/volume/flexvolume/mounter.go @@ -17,6 +17,7 @@ limitations under the License. package flexvolume import ( + "os" "strconv" "k8s.io/kubernetes/pkg/volume" @@ -70,6 +71,7 @@ func (f *flexVolumeMounter) SetUpAt(dir string, fsGroup *int64) error { // Extract secret and pass it as options. if err := addSecretsToOptions(extraOptions, f.spec, f.podNamespace, f.driverName, f.plugin.host); err != nil { + os.Remove(dir) return err } @@ -86,6 +88,7 @@ func (f *flexVolumeMounter) SetUpAt(dir string, fsGroup *int64) error { } if err != nil { + os.Remove(dir) return err }