Repository: spark Updated Branches: refs/heads/branch-1.1 e5ab11387 -> 85dd5139e
Fixed the condition in StronglyConnectedComponents Issue: SPARK-3635 Author: oded <[email protected]> Closes #2486 from odedz/master and squashes the following commits: dd7890a [oded] Fixed the condition in StronglyConnectedComponents Issue: SPARK-3635 (cherry picked from commit dc30e4504abcda1774f5f09a08bba73d29a2898b) Signed-off-by: Ankur Dave <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/85dd5139 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/85dd5139 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/85dd5139 Branch: refs/heads/branch-1.1 Commit: 85dd5139e1fcd23efcc987b2bb7590caa53ee6bf Parents: e5ab113 Author: oded <[email protected]> Authored: Mon Sep 29 18:05:53 2014 -0700 Committer: Ankur Dave <[email protected]> Committed: Mon Sep 29 18:07:12 2014 -0700 ---------------------------------------------------------------------- .../org/apache/spark/graphx/lib/StronglyConnectedComponents.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/85dd5139/graphx/src/main/scala/org/apache/spark/graphx/lib/StronglyConnectedComponents.scala ---------------------------------------------------------------------- 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 46da38e..8dd9580 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() --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
