diff --git a/graphx/src/main/scala/org/apache/spark/graphx/lib/PageRank.scala b/graphx/src/main/scala/org/apache/spark/graphx/lib/PageRank.scala index 614555a054df..b506fcc73ff6 100644 --- a/graphx/src/main/scala/org/apache/spark/graphx/lib/PageRank.scala +++ b/graphx/src/main/scala/org/apache/spark/graphx/lib/PageRank.scala @@ -98,7 +98,7 @@ object PageRank extends Logging { Iterator((edge.dstId, edge.srcAttr * edge.attr)) def messageCombiner(a: Double, b: Double): Double = a + b // The initial message received by all vertices in PageRank - val initialMessage = 0.0 + val initialMessage = 1.0 // Execute pregel for a fixed number of iterations. Pregel(pagerankGraph, initialMessage, numIter, activeDirection = EdgeDirection.Out)(