You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by pa...@apache.org on 2014/06/19 04:17:56 UTC
git commit: updated refs/heads/trunk to b218d72
Repository: giraph
Updated Branches:
refs/heads/trunk 64428a9d0 -> b218d72ce
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/trunk
Commit: b218d72cedc52467e691c6002e596e482d8583e4
Parents: 64428a9
Author: Pavan Kumar <pa...@fb.com>
Authored: Wed Jun 18 19:16:32 2014 -0700
Committer: Pavan Kumar <pa...@fb.com>
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