I think this is a separate issue with how the EdgeRDDImpl partitions
edges. If you can merge this change in and rebuild, it should work:
https://github.com/apache/spark/pull/4136/files
If you can't, I just called the Graph.partitonBy() method right after
construction my graph but before perfo
On 01/29/2015 08:31 PM, Ankur Dave wrote:
Thanks for the reminder. I just created a PR:
https://github.com/apache/spark/pull/4273
Ankur
Hello,
Thanks for the patch. I applied it on Pregel.scala (in Spark 1.2.0 sources) and
rebuilt
Spark. During execution, at the 25th iteration of Pregel, che
Thanks for the reminder. I just created a PR:
https://github.com/apache/spark/pull/4273
Ankur
On Thu, Jan 29, 2015 at 7:25 AM, Jay Hutfles wrote:
> Just curious, is this set to be merged at some point?
-
To unsubscribe, e-mail:
Just curious, is this set to be merged at some point?
On Thu Jan 22 2015 at 4:34:46 PM Ankur Dave wrote:
> At 2015-01-22 02:06:37 -0800, NicolasC wrote:
> > I try to execute a simple program that runs the ShortestPaths algorithm
> > (org.apache.spark.graphx.lib.ShortestPaths) on a small grid gr
At 2015-01-22 02:06:37 -0800, NicolasC wrote:
> I try to execute a simple program that runs the ShortestPaths algorithm
> (org.apache.spark.graphx.lib.ShortestPaths) on a small grid graph.
> I use Spark 1.2.0 downloaded from spark.apache.org.
>
> This program runs more than 2 hours when the grid s
Hello,
I try to execute a simple program that runs the ShortestPaths algorithm
(org.apache.spark.graphx.lib.ShortestPaths) on a small grid graph.
I use Spark 1.2.0 downloaded from spark.apache.org.
The program's code is the following :
object GraphXGridSP {
def main(args : Array[String])
