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 614555a054dfb..42c3125c46691 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 @@ -139,7 +139,8 @@ object PageRank extends Logging { // version of Pregel def vertexProgram(id: VertexId, attr: (Double, Double), msgSum: Double): (Double, Double) = { val (oldPR, lastDelta) = attr - val newPR = oldPR + (1.0 - resetProb) * msgSum + // Equation: resetProb * (1-resetProb)*msgSum + val newPR = resetProb + (1.0 - resetProb) * msgSum (newPR, newPR - oldPR) }