Ted Yu created FLINK-7631:
-----------------------------
Summary: Ineffective check in PageRank#open()
Key: FLINK-7631
URL: https://issues.apache.org/jira/browse/FLINK-7631
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
Priority: Minor
>From
>flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/linkanalysis/PageRank.java
> :
{code}
this.vertexCount = vertexCountIterator.hasNext() ?
vertexCountIterator.next().getValue() : 0;
this.uniformlyDistributedScore = ((1 - dampingFactor) + dampingFactor *
sumOfSinks) / this.vertexCount;
{code}
The check for vertexCountIterator.hasNext() should enclose the assignments to
both this.vertexCount and this.uniformlyDistributedScore
Otherwise there may be divide by zero error.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
