From 85dd5139e1fcd23efcc987b2bb7590caa53ee6bf Mon Sep 17 00:00:00 2001
From: oded <oded@HP-DV6.c4internal.c4-security.com>
Date: Mon, 29 Sep 2014 18:05:53 -0700
Subject: [PATCH] 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
(cherry picked from commit dc30e4504abcda1774f5f09a08bba73d29a2898b)
Signed-off-by: Ankur Dave <ankurdave@gmail.com>
---
.../apache/spark/graphx/lib/StronglyConnectedComponents.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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()
--
GitLab