GIRAPH-613
Project: http://git-wip-us.apache.org/repos/asf/giraph/repo Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/67e0f11d Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/67e0f11d Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/67e0f11d Branch: refs/heads/trunk Commit: 67e0f11d2bd98e0614b26d4ea6dd707e6f65a105 Parents: 6cf79db Author: Claudio Martella <[email protected]> Authored: Thu Apr 11 19:10:52 2013 +0200 Committer: Claudio Martella <[email protected]> Committed: Thu Apr 11 19:10:52 2013 +0200 ---------------------------------------------------------------------- .../main/java/org/apache/giraph/graph/Vertex.java | 2 +- .../giraph/partition/ByteArrayPartition.java | 4 ++++ 2 files changed, 5 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/giraph/blob/67e0f11d/giraph-core/src/main/java/org/apache/giraph/graph/Vertex.java ---------------------------------------------------------------------- diff --git a/giraph-core/src/main/java/org/apache/giraph/graph/Vertex.java b/giraph-core/src/main/java/org/apache/giraph/graph/Vertex.java index a1b1a87..ade25fe 100644 --- a/giraph-core/src/main/java/org/apache/giraph/graph/Vertex.java +++ b/giraph-core/src/main/java/org/apache/giraph/graph/Vertex.java @@ -40,7 +40,7 @@ import java.util.Iterator; /** * Basic abstract class for writing a BSP application for computation. - * Giraph will checkpoint Vertex value and edges, hence all user data should + * Giraph will store Vertex value and edges, hence all user data should * be stored as part of the vertex value. * * @param <I> Vertex id http://git-wip-us.apache.org/repos/asf/giraph/blob/67e0f11d/giraph-core/src/main/java/org/apache/giraph/partition/ByteArrayPartition.java ---------------------------------------------------------------------- diff --git a/giraph-core/src/main/java/org/apache/giraph/partition/ByteArrayPartition.java b/giraph-core/src/main/java/org/apache/giraph/partition/ByteArrayPartition.java index d2e7599..b7ec924 100644 --- a/giraph-core/src/main/java/org/apache/giraph/partition/ByteArrayPartition.java +++ b/giraph-core/src/main/java/org/apache/giraph/partition/ByteArrayPartition.java @@ -70,6 +70,10 @@ public class ByteArrayPartition<I extends WritableComparable, vertexMap = new MapMaker().concurrencyLevel( getConf().getNettyServerExecutionConcurrency()).makeMap(); representativeVertex = getConf().createVertex(); + representativeVertex.initialize( + getConf().createVertexId(), + getConf().createVertexValue(), + getConf().createVertexEdges()); useUnsafeSerialization = getConf().useUnsafeSerialization(); }
