The makeClusterMPI() function creates an MPI cluster of R workers
for parallel processing. This function utilizes
makeCluster(..., type = "MPI") of the parallel package and
tweaks the cluster in an attempt to avoid
stopCluster() from hanging (1).
WARNING: This function is very much in a beta version and should
only be used if parallel::makeCluster(..., type = "MPI") fails.
makeClusterMPI(
workers,
...,
autoStop = FALSE,
verbose = getOption("future.debug", FALSE)
)The number workers (as a positive integer).
Optional arguments passed to
makeCluster(workers, type = "MPI", ...).
If TRUE, the cluster will be automatically stopped
(using stopCluster()) when it is
garbage collected, unless already stopped.
If TRUE, informative messages are outputted.
An object of class c("RichMPIcluster", "MPIcluster", "cluster") consisting
of a list of "MPInode" workers.
Creating MPI clusters requires the Rmpi package.
R-sig-hpc thread Rmpi: mpi.close.Rslaves() 'hangs' on 2017-09-28.