Shouldn't I be seeing N2 and N4 in the output below? (Spark 0.9.0 REPL) Or am I
missing something fundamental?
val nodes = sc.parallelize(Array((1L, N1), (2L, N2), (3L, N3), (4L,
N4), (5L, N5)))
val edges = sc.parallelize(Array(Edge(1L, 2L, E1), Edge(1L, 3L, E2),
Edge(2L, 4L, E3), Edge(3L,
Take a look at this one: https://issues.apache.org/jira/browse/SPARK-1188
It was an optimization that added user inconvenience. We got rid of that
now in Spark 1.0.
On Wed, May 28, 2014 at 11:48 PM, Michael Malak michaelma...@yahoo.comwrote:
Shouldn't I be seeing N2 and N4 in the output
