diff --git a/internal/cephfs/controllerserver.go b/internal/cephfs/controllerserver.go index dc314976d..298b09598 100644 --- a/internal/cephfs/controllerserver.go +++ b/internal/cephfs/controllerserver.go @@ -386,6 +386,13 @@ func (cs *ControllerServer) CreateVolume( return nil, status.Error(codes.Internal, err.Error()) } + + // Set Metadata on PV Create + metadata := k8s.GetVolumeMetadata(req.GetParameters()) + err = volClient.SetAllMetadata(metadata) + if err != nil { + return nil, status.Error(codes.Internal, err.Error()) + } } log.DebugLog(ctx, "cephfs: successfully created backing volume named %s for request name %s",