diff options
| author | Ankur Dave <ankurdave@gmail.com> | 2014-01-13 22:20:45 -0800 |
|---|---|---|
| committer | Ankur Dave <ankurdave@gmail.com> | 2014-01-13 22:20:45 -0800 |
| commit | 76ebdae79866f4721ef39aaccfa89a255d3cea6a (patch) | |
| tree | d513aca66e9974e71d1772f8993fff08e99a94a5 /graphx | |
| parent | c6dbfd16942f1dc0673071580ca968dd4f8428da (diff) | |
| download | spark-76ebdae79866f4721ef39aaccfa89a255d3cea6a.tar.gz spark-76ebdae79866f4721ef39aaccfa89a255d3cea6a.tar.bz2 spark-76ebdae79866f4721ef39aaccfa89a255d3cea6a.zip | |
Fix bug in GraphLoader.edgeListFile that caused srcId > dstId
Diffstat (limited to 'graphx')
| -rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/GraphLoader.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 7bdb101efb..5904aa3a28 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) |