diff --git a/internal/cephfs/core/fsjournal.go b/internal/cephfs/core/fsjournal.go index b9d57e8c2..f22b7b9a8 100644 --- a/internal/cephfs/core/fsjournal.go +++ b/internal/cephfs/core/fsjournal.go @@ -124,6 +124,11 @@ func CheckVolExists(ctx context.Context, return nil, cerrors.ErrClonePending } if cloneState == cephFSCloneFailed { + log.ErrorLog(ctx, + "clone failed, deleting subvolume clone. vol=%s, subvol=%s subvolgroup=%s", + volOptions.FsName, + vid.FsSubvolName, + volOptions.SubvolumeGroup) err = volOptions.PurgeVolume(ctx, fsutil.VolumeID(vid.FsSubvolName), true) if err != nil { log.ErrorLog(ctx, "failed to delete volume %s: %v", vid.FsSubvolName, err)