svn commit: r1573269 - in /hama/trunk: CHANGES.txt graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java

[edwardyoon]

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));
           }