hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1573269 - in /hama/trunk: CHANGES.txt graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java
Date Sun, 02 Mar 2014 07:28:20 GMT
Author: edwardyoon
Date: Sun Mar  2 07:28:20 2014
New Revision: 1573269

URL: http://svn.apache.org/r1573269
Log:
HAMA-880: Check whether input records are in order by vertex ID (edwardyoon)

Modified:
    hama/trunk/CHANGES.txt
    hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java

Modified: hama/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hama/trunk/CHANGES.txt?rev=1573269&r1=1573268&r2=1573269&view=diff
==============================================================================
--- hama/trunk/CHANGES.txt (original)
+++ hama/trunk/CHANGES.txt Sun Mar  2 07:28:20 2014
@@ -30,6 +30,7 @@ Release 0.7.0 (unreleased changes)
 
   IMPROVEMENTS
 
+   HAMA-880: Check whether input records are in order by vertex ID (edwardyoon)
    HAMA-879: Errors for messages with wrong destination should be more clear (Anastasis Andronidis
via edwardyoon)
    HAMA-873: Display counters of job on master's web page (Saisai Shao via edwardyoon)
    HAMA-870: Runtime message compression in Bundle (edwardyoon)

Modified: hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java
URL: http://svn.apache.org/viewvc/hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java?rev=1573269&r1=1573268&r2=1573269&view=diff
==============================================================================
--- hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java (original)
+++ hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java Sun Mar  2 07:28:20
2014
@@ -428,6 +428,10 @@ public final class GraphJobRunner<V exte
             vertex.addEdge(edge);
           }
         } else {
+          if (vertex.compareTo(currentVertex) > 0) {
+            throw new IOException("The records of split aren't in order by vertex ID.");
 
+          }
+          
           if (selfReference) {
             vertex.addEdge(new Edge<V, E>(vertex.getVertexID(), null));
           }



Mime
View raw message