You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by an...@apache.org on 2014/09/30 03:06:45 UTC
git commit: Fixed the condition in StronglyConnectedComponents Issue:
SPARK-3635
Repository: spark
Updated Branches:
refs/heads/master 51229ff7f -> dc30e4504
Fixed the condition in StronglyConnectedComponents Issue: SPARK-3635
Author: oded <od...@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
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 <od...@HP-DV6.c4internal.c4-security.com>
Authored: Mon Sep 29 18:05:53 2014 -0700
Committer: Ankur Dave <an...@gmail.com>
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: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org