You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/01/14 08:00:09 UTC

[45/50] git commit: Fix bug in GraphLoader.edgeListFile that caused srcId > dstId

Fix bug in GraphLoader.edgeListFile that caused srcId > dstId


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

Branch: refs/heads/master
Commit: 76ebdae79866f4721ef39aaccfa89a255d3cea6a
Parents: c6dbfd1
Author: Ankur Dave <an...@gmail.com>
Authored: Mon Jan 13 22:20:45 2014 -0800
Committer: Ankur Dave <an...@gmail.com>
Committed: Mon Jan 13 22:20:45 2014 -0800

----------------------------------------------------------------------
 graphx/src/main/scala/org/apache/spark/graphx/GraphLoader.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/76ebdae7/graphx/src/main/scala/org/apache/spark/graphx/GraphLoader.scala
----------------------------------------------------------------------
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/GraphLoader.scala b/graphx/src/main/scala/org/apache/spark/graphx/GraphLoader.scala
index 7bdb101..5904aa3 100644
--- a/graphx/src/main/scala/org/apache/spark/graphx/GraphLoader.scala
+++ b/graphx/src/main/scala/org/apache/spark/graphx/GraphLoader.scala
@@ -53,7 +53,7 @@ object GraphLoader extends Logging {
           }
           val srcId = lineArray(0).toLong
           val dstId = lineArray(1).toLong
-          if (canonicalOrientation && dstId > srcId) {
+          if (canonicalOrientation && srcId > dstId) {
             builder.add(dstId, srcId, 1)
           } else {
             builder.add(srcId, dstId, 1)