It's not allowed to use RDD in map function.
RDD can only operated at driver of spark program.
At your case, group RDD can't be found at every executor.
I guess you want to implement subquery like operation, try to use
RDD.intersection() or join()
2014-08-29 12:43 GMT+08:00 Gary Zhao
Hello
I'm new to Spark and playing around, but saw the following error. Could
anyone to help on it?
Thanks
Gary
scala c
res15: org.apache.spark.rdd.RDD[String] = FlatMappedRDD[7] at flatMap at
console:23
scala group
res16: org.apache.spark.rdd.RDD[(String, Iterable[String])] =
