複数の mclapply/parLapply をチェーンしようとしています:
my_function<-function(x){
do something;
mclapply()
}
次に、x を変化させます。
mclapply(1:100,function(i)(function(x[i])),mc.cores=60)
問題は、次のエラーが頻繁に発生することです。
スケジュールされたコア 3、57、54、8、23、17、53、18、22、28、41、25、30 ユーザー コードでエラーが発生しました。ジョブのすべての値が影響を受けます
興味深いことに、ubuntu マシンでこれを実行している場合はエラーが発生しませんが、CentOS マシンでこれを実行するとこのエラーが発生します。parLapply を使用して 2 番目のステップを実行すると、同様のことが起こります
私も試しました：
cl <- makePSOCKcluster(no_cores)
clusterExport(cl,c("function_main_simulation","a1","a2","no_cores"))
system.time(parLapply(cl,1:10000,function(i)(function_main_simulation(a1,a2))))
stopCluster(cl)
しかし、ここでも興味深いエラーが発生します。