diff --git a/pkg/volume/csi/csi_mounter.go b/pkg/volume/csi/csi_mounter.go index 693a011f798..fcbe7e24ef2 100644 --- a/pkg/volume/csi/csi_mounter.go +++ b/pkg/volume/csi/csi_mounter.go @@ -397,12 +397,19 @@ func removeMountDir(plug *csiPlugin, mountPath string) error { return err } // remove volume data file as well - dataFile := path.Join(path.Dir(mountPath), volDataFileName) + volPath := path.Dir(mountPath) + dataFile := path.Join(volPath, volDataFileName) glog.V(4).Info(log("also deleting volume info data file [%s]", dataFile)) if err := os.Remove(dataFile); err != nil && !os.IsNotExist(err) { glog.Error(log("failed to delete volume data file [%s]: %v", dataFile, err)) return err } + // remove volume path + glog.V(4).Info(log("deleting volume path [%s]", volPath)) + if err := os.Remove(volPath); err != nil && !os.IsNotExist(err) { + glog.Error(log("failed to delete volume path [%s]: %v", volPath, err)) + return err + } } return nil }