[jira] [Assigned] (SPARK-4600) org.apache.spark.graphx.VertexRDD.diff does not work

["Sean Owen (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/SPARK-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Sean Owen reassigned SPARK-4600:
--------------------------------

    Assignee: Brennon York

> org.apache.spark.graphx.VertexRDD.diff does not work
> ----------------------------------------------------
>
>                 Key: SPARK-4600
>                 URL: https://issues.apache.org/jira/browse/SPARK-4600
>             Project: Spark
>          Issue Type: Bug
>          Components: GraphX
>         Environment: scala 2.10.4
> spark 1.1.0
>            Reporter: Teppei Tosa
>            Assignee: Brennon York
>              Labels: graphx
>
> VertexRDD.diff doesn't work.
> For example : 
> val setA: VertexRDD[Int] = VertexRDD(sc.parallelize(0L until 2L).map(id => (id, id.toInt)))
> setA.collect.foreach(println(_))
> // (0,0)
> // (1,1)
> val setB: VertexRDD[Int] = VertexRDD(sc.parallelize(1L until 3L).map(id => (id, id.toInt)))
> setB.collect.foreach(println(_))
> // (1,1)
> // (2,2)
> val diff = setA.diff(setB)
> diff.collect.foreach(println(_))
> // printed none



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org