Repository: spark Updated Branches: refs/heads/master 51229ff7f -> dc30e4504
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 Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/dc30e450 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/dc30e450 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/dc30e450 Branch: refs/heads/master Commit: dc30e4504abcda1774f5f09a08bba73d29a2898b Parents: 51229ff Author: oded <[email protected]> Authored: Mon Sep 29 18:05:53 2014 -0700 Committer: Ankur Dave <[email protected]> Committed: Mon Sep 29 18:05:53 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/dc30e450/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]
