[FLINK-1201] [gelly] [sssp example] only update the vertex value if new distance is smaller
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d57a9d7a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d57a9d7a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d57a9d7a Branch: refs/heads/master Commit: d57a9d7ab59243e78836fb7bd4120106071a3d49 Parents: 3f60009 Author: vasia <vasilikikala...@gmail.com> Authored: Tue Dec 30 13:48:53 2014 +0200 Committer: Stephan Ewen <se...@apache.org> Committed: Wed Feb 11 10:46:13 2015 +0100 ---------------------------------------------------------------------- .../apache/flink/graph/library/SingleSourceShortestPaths.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/d57a9d7a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SingleSourceShortestPaths.java ---------------------------------------------------------------------- diff --git a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SingleSourceShortestPaths.java b/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SingleSourceShortestPaths.java index 632233c..7f72f2a 100644 --- a/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SingleSourceShortestPaths.java +++ b/flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SingleSourceShortestPaths.java @@ -71,10 +71,8 @@ public class SingleSourceShortestPaths<K extends Comparable<K> & Serializable> i } if (vertexValue > minDistance) { - vertexValue = minDistance; + setNewVertexValue(minDistance); } - - setNewVertexValue(vertexValue); } }
