diff --git a/internal/cephfs/nodeserver.go b/internal/cephfs/nodeserver.go index fdadb6497..65c1aa3d1 100644 --- a/internal/cephfs/nodeserver.go +++ b/internal/cephfs/nodeserver.go @@ -126,12 +126,18 @@ func (ns *NodeServer) NodeStageVolume( } defer volOptions.Destroy() - volOptions.NetNamespaceFilePath, err = util.GetCephFSNetNamespaceFilePath( - util.CsiConfigFile, - volOptions.ClusterID) - if err != nil { - return nil, status.Error(codes.Internal, err.Error()) + // Skip extracting NetNamespaceFilePath if the clusterID is empty. + // In case of pre-provisioned volume the clusterID is not set in the + // volume context. + if volOptions.ClusterID != "" { + volOptions.NetNamespaceFilePath, err = util.GetCephFSNetNamespaceFilePath( + util.CsiConfigFile, + volOptions.ClusterID) + if err != nil { + return nil, status.Error(codes.Internal, err.Error()) + } } + mnt, err := mounter.New(volOptions) if err != nil { log.ErrorLog(ctx, "failed to create mounter for volume %s: %v", volID, err)