fix build error (pavanka)

Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/b218d72c
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/b218d72c
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/b218d72c

Branch: refs/heads/release-1.1
Commit: b218d72cedc52467e691c6002e596e482d8583e4
Parents: 64428a9
Author: Pavan Kumar <[email protected]>
Authored: Wed Jun 18 19:16:32 2014 -0700
Committer: Pavan Kumar <[email protected]>
Committed: Wed Jun 18 19:16:32 2014 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/giraph/edge/AbstractEdgeStore.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/giraph/blob/b218d72c/giraph-core/src/main/java/org/apache/giraph/edge/AbstractEdgeStore.java
----------------------------------------------------------------------
diff --git 
a/giraph-core/src/main/java/org/apache/giraph/edge/AbstractEdgeStore.java 
b/giraph-core/src/main/java/org/apache/giraph/edge/AbstractEdgeStore.java
index b40ac00..dc7a5b4 100644
--- a/giraph-core/src/main/java/org/apache/giraph/edge/AbstractEdgeStore.java
+++ b/giraph-core/src/main/java/org/apache/giraph/edge/AbstractEdgeStore.java
@@ -224,7 +224,6 @@ public abstract class AbstractEdgeStore<I extends 
WritableComparable,
                 I vertexId = getVertexId(entry, representativeVertexId);
                 OutEdges<I, E> outEdges = convertInputToComputeEdges(
                   getPartitionEdges(entry));
-                iterator.remove();
                 Vertex<I, V, E> vertex = partition.getVertex(vertexId);
                 // If the source vertex doesn't exist, create it. Otherwise,
                 // just set the edges.
@@ -250,6 +249,7 @@ public abstract class AbstractEdgeStore<I extends 
WritableComparable,
                   // require us to put back the vertex after modifying it.
                   partition.saveVertex(vertex);
                 }
+                iterator.remove();
               }
               // Some PartitionStore implementations
               // (e.g. DiskBackedPartitionStore) require us to put back the

Reply via email to