diff options
| author | oded <oded@HP-DV6.c4internal.c4-security.com> | 2014-09-29 18:05:53 -0700 |
|---|---|---|
| committer | Ankur Dave <ankurdave@gmail.com> | 2014-09-29 18:05:53 -0700 |
| commit | dc30e4504abcda1774f5f09a08bba73d29a2898b (patch) | |
| tree | b8aba17ef505e79a84fc917cb2493333b076a2ff /graphx/src | |
| parent | 51229ff7f4d3517706a1cdc1a2943ede1c605089 (diff) | |
| download | spark-dc30e4504abcda1774f5f09a08bba73d29a2898b.tar.gz spark-dc30e4504abcda1774f5f09a08bba73d29a2898b.tar.bz2 spark-dc30e4504abcda1774f5f09a08bba73d29a2898b.zip | |
Fixed the condition in StronglyConnectedComponents Issue: SPARK-3635
Author: oded <oded@HP-DV6.c4internal.c4-security.com>
Closes #2486 from odedz/master and squashes the following commits:
dd7890a [oded] Fixed the condition in StronglyConnectedComponents Issue: SPARK-3635
Diffstat (limited to 'graphx/src')
| -rw-r--r-- | graphx/src/main/scala/org/apache/spark/graphx/lib/StronglyConnectedComponents.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/lib/StronglyConnectedComponents.scala b/graphx/src/main/scala/org/apache/spark/graphx/lib/StronglyConnectedComponents.scala index 46da38eeb7..8dd958033b 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/lib/StronglyConnectedComponents.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/lib/StronglyConnectedComponents.scala @@ -75,7 +75,7 @@ object StronglyConnectedComponents { sccWorkGraph, Long.MaxValue, activeDirection = EdgeDirection.Out)( (vid, myScc, neighborScc) => (math.min(myScc._1, neighborScc), myScc._2), e => { - if (e.srcId < e.dstId) { + if (e.srcAttr._1 < e.dstAttr._1) { Iterator((e.dstId, e.srcAttr._1)) } else { Iterator() |