m****e 发帖数: 488 | 1 需要用R做并行运算。我运用的算法大体如下:
library(snowfall)
sfInit(parallel=TRUE, cpus=3,type="SOCK") #for windows
sfExportAll( )
library(fAsianOptions) # for kummerU
……
segment<-function(x){
……
kummerU(x…)
……
}
sfLapply(1:M,segment)
……
sfStop()
运算老是出错。出错信息如下:
Error in checkForRemoteErrors(val) :
3 nodes produced errors; first error: could not find function "kummerU"
这个是说找不到“kummerU”? 可是有library(fAsianOptions),而且单独运算的时候也
没这个问题。
谢谢~ |
m****e 发帖数: 488 | 2 DING
【在 m****e 的大作中提到】 : 需要用R做并行运算。我运用的算法大体如下: : library(snowfall) : sfInit(parallel=TRUE, cpus=3,type="SOCK") #for windows : sfExportAll( ) : library(fAsianOptions) # for kummerU : …… : segment<-function(x){ : …… : kummerU(x…) : ……
|
t*****i 发帖数: 426 | 3 没有研究过这个问题,但是好像在哪儿看到过类似的问题,不是用snowfall,用的是
snow。是不是只有在master node 上安装了你要用的library,在slave node上没有安
装? |
d******k 发帖数: 141 | 4 不是很确定我的想法,我猜测下,那个sfExportAll()在library(fAsianOptions)的前
面,那么fAsianOptions可能只在master processor上load了,没有被exported到slave
processors上?是不是把这两行命令调换下顺序?
我最近也在接触parallel computing in R的东西,能不能顺便问下,你大概是要解决
什么问题从而要用到parallel computing的?谢谢~
【在 m****e 的大作中提到】 : 需要用R做并行运算。我运用的算法大体如下: : library(snowfall) : sfInit(parallel=TRUE, cpus=3,type="SOCK") #for windows : sfExportAll( ) : library(fAsianOptions) # for kummerU : …… : segment<-function(x){ : …… : kummerU(x…) : ……
|
m****e 发帖数: 488 | 5 都安了啊
【在 t*****i 的大作中提到】 : 没有研究过这个问题,但是好像在哪儿看到过类似的问题,不是用snowfall,用的是 : snow。是不是只有在master node 上安装了你要用的library,在slave node上没有安 : 装?
|
m****e 发帖数: 488 | 6 哦,我只是R code运行太慢,要提交到server上去运算 :)
slave
【在 d******k 的大作中提到】 : 不是很确定我的想法,我猜测下,那个sfExportAll()在library(fAsianOptions)的前 : 面,那么fAsianOptions可能只在master processor上load了,没有被exported到slave : processors上?是不是把这两行命令调换下顺序? : 我最近也在接触parallel computing in R的东西,能不能顺便问下,你大概是要解决 : 什么问题从而要用到parallel computing的?谢谢~
|
k*******a 发帖数: 772 | 7 Not sure about snowfall package, but in snow package, you need to initialize
for each node. That means you need to load the library for each node.
You can try to download/buy the book "Parallel R", which explained in
details |