spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ankurd...@apache.org
Subject spark git commit: [SPARK-4249][GraphX]fix a problem of EdgePartitionBuilder in Graphx
Date Thu, 06 Nov 2014 18:48:39 GMT
Repository: spark
Updated Branches:
  refs/heads/branch-1.1 c58c1bb83 -> 0a40eac25


[SPARK-4249][GraphX]fix a problem of EdgePartitionBuilder in Graphx

at first srcIds is not initialized and are all 0. so we use edgeArray(0).srcId to currSrcId

Author: lianhuiwang <lianhuiwang09@gmail.com>

Closes #3138 from lianhuiwang/SPARK-4249 and squashes the following commits:

3f4e503 [lianhuiwang] fix a problem of EdgePartitionBuilder in Graphx

(cherry picked from commit d15c6e9dc2860bbe56e31ddf71218ccc6d5c841d)
Signed-off-by: Ankur Dave <ankurdave@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/0a40eac2
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/0a40eac2
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/0a40eac2

Branch: refs/heads/branch-1.1
Commit: 0a40eac25a0202c492f58e3c97a96a35ceed6ce8
Parents: c58c1bb
Author: lianhuiwang <lianhuiwang09@gmail.com>
Authored: Thu Nov 6 10:46:45 2014 -0800
Committer: Ankur Dave <ankurdave@gmail.com>
Committed: Thu Nov 6 10:48:32 2014 -0800

----------------------------------------------------------------------
 .../org/apache/spark/graphx/impl/EdgePartitionBuilder.scala      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/0a40eac2/graphx/src/main/scala/org/apache/spark/graphx/impl/EdgePartitionBuilder.scala
----------------------------------------------------------------------
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/impl/EdgePartitionBuilder.scala
b/graphx/src/main/scala/org/apache/spark/graphx/impl/EdgePartitionBuilder.scala
index 4520beb..2b6137b 100644
--- a/graphx/src/main/scala/org/apache/spark/graphx/impl/EdgePartitionBuilder.scala
+++ b/graphx/src/main/scala/org/apache/spark/graphx/impl/EdgePartitionBuilder.scala
@@ -45,8 +45,8 @@ class EdgePartitionBuilder[@specialized(Long, Int, Double) ED: ClassTag,
VD: Cla
     // Copy edges into columnar structures, tracking the beginnings of source vertex id clusters
and
     // adding them to the index
     if (edgeArray.length > 0) {
-      index.update(srcIds(0), 0)
-      var currSrcId: VertexId = srcIds(0)
+      index.update(edgeArray(0).srcId, 0)
+      var currSrcId: VertexId = edgeArray(0).srcId
       var i = 0
       while (i < edgeArray.size) {
         srcIds(i) = edgeArray(i).srcId


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


Mime
View raw message