ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fixed the condition in StronglyConnectedComponents Issue: SPARK-3635

Browse source 
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
This commit is contained in:
oded 2014-09-29 18:05:53 -07:00 committed by Ankur Dave
parent 51229ff7f4
commit dc30e4504a
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
graphx/src/main/scala/org/apache/spark/graphx/lib/StronglyConnectedComponents.scala
View file

@ -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()