我试图从https://jeffreybreen.wordpress.com/2011/01/10/segue-r-to-amazon-elastic-mapreduce-hadoop/Emrlapply并不简单的任务,工作
集群创建复制使用segue
的简单的例子是成功的
> cl <- createCluster(numInstances=2)
STARTING - 2012-05-27 14:02:08
STARTING - 2012-05-27 14:02:39
STARTING - 2012-05-27 14:03:10
STARTING - 2012-05-27 14:03:42
STARTING - 2012-05-27 14:04:13
STARTING - 2012-05-27 14:04:44
STARTING - 2012-05-27 14:05:15
STARTING - 2012-05-27 14:05:46
STARTING - 2012-05-27 14:06:17
BOOTSTRAPPING - 2012-05-27 14:06:48
BOOTSTRAPPING - 2012-05-27 14:07:19
BOOTSTRAPPING - 2012-05-27 14:07:50
BOOTSTRAPPING - 2012-05-27 14:08:21
BOOTSTRAPPING - 2012-05-27 14:08:52
BOOTSTRAPPING - 2012-05-27 14:09:23
BOOTSTRAPPING - 2012-05-27 14:09:55
WAITING - 2012-05-27 14:10:26
Your Amazon EMR Hadoop Cluster is ready for action.
Remember to terminate your cluster with stopCluster().
Amazon is billing you!
本地模拟还行,但在运行它每次都会返回一个错误。
> myList <- NULL
> set.seed(1)
> for (i in 1:10){
+ a <- c(rnorm(999), NA)
+ myList[[i]] <- a
+ }
> outputLocal <- lapply(myList, mean, na.rm=T)
> outputEmr <- emrlapply(cl, myList, mean, na.rm=T)
RUNNING - 2012-05-27 14:11:58
RUNNING - 2012-05-27 14:12:29
RUNNING - 2012-05-27 14:13:00
WAITING - 2012-05-27 14:13:31
Error in lines[[i]] : subgroup is out of range
> stopCluster(cl)
我喜欢这个包的想法,我希望这将是我的工作是有用的,但我无法弄清楚如何解决这个基本问题。
segue
版0.02
OS的:Ubuntu的11.10
UPDATE:我试图运行裨估计的另一示例的测试用例,并且emrlapply
返回相同的错误消息。
UPDATE2: 我更新到版本0.03,现在我无法连接到群集。成功启动实例后,尝试关闭而没有任何效果。我通过AWS consol终止了实例。所以旧问题解决了,但新问题出现了。
> cl <- createCluster(numInstances=2)
STARTING - 2012-06-01 22:36:10
STARTING - 2012-06-01 22:36:41
STARTING - 2012-06-01 22:37:12
STARTING - 2012-06-01 22:37:43
STARTING - 2012-06-01 22:38:14
STARTING - 2012-06-01 22:38:46
SHUTTING_DOWN - 2012-06-01 22:39:17
SHUTTING_DOWN - 2012-06-01 22:39:48
...
SHUTTING_DOWN - 2012-06-01 22:48:05
SHUTTING_DOWN - 2012-06-01 22:48:36
FAILED - 2012-06-01 22:49:07
>
寻呼@jdlong现场 – Chase
好“好”消息是,我可以重现你的错误。我现在正在调试,看看我能否弄清楚发生了什么。 –
@JDLong,谢谢你的回应!奇怪的是,别人之前没有发现这个问题。 – DrDom