flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [05/50] [abbrv] flink git commit: [FLINK-1201] [gelly] [sssp example] only update the vertex value if new distance is smaller
Date Wed, 11 Feb 2015 10:49:07 GMT
[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 <vasilikikalavri@gmail.com>
Authored: Tue Dec 30 13:48:53 2014 +0200
Committer: Stephan Ewen <sewen@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);
         }
     }
 


Mime
View raw message