You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by ma...@apache.org on 2018/02/13 23:42:55 UTC
git commit: updated refs/heads/trunk to 94a3ac5
Repository: giraph
Updated Branches:
refs/heads/trunk 14845725e -> 94a3ac5fb
closes #59
Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/94a3ac5f
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/94a3ac5f
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/94a3ac5f
Branch: refs/heads/trunk
Commit: 94a3ac5fbd184bde121f94895a5bdf22cf034d70
Parents: 1484572
Author: Maja Kabiljo <ma...@fb.com>
Authored: Tue Feb 13 15:42:12 2018 -0800
Committer: Maja Kabiljo <ma...@fb.com>
Committed: Tue Feb 13 15:42:43 2018 -0800
----------------------------------------------------------------------
.../org/apache/giraph/ooc/data/DiskBackedPartitionStore.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/giraph/blob/94a3ac5f/giraph-core/src/main/java/org/apache/giraph/ooc/data/DiskBackedPartitionStore.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/ooc/data/DiskBackedPartitionStore.java b/giraph-core/src/main/java/org/apache/giraph/ooc/data/DiskBackedPartitionStore.java
index 6b7822f..14ba6d1 100644
--- a/giraph-core/src/main/java/org/apache/giraph/ooc/data/DiskBackedPartitionStore.java
+++ b/giraph-core/src/main/java/org/apache/giraph/ooc/data/DiskBackedPartitionStore.java
@@ -244,6 +244,9 @@ public class DiskBackedPartitionStore<I extends WritableComparable,
I id = conf.createVertexId();
id.readFields(in);
Vertex<I, V, E> v = partition.getVertex(id);
+ checkNotNull(v, "Vertex with ID " + id + " not found in partition " +
+ partition.getId() + " which has " + partition.getVertexCount() +
+ " vertices and " + partition.getEdgeCount() + " edges.");
OutEdges<I, E> edges = (OutEdges<I, E>) v.getEdges();
edges.readFields(in);
partition.saveVertex(v);
@@ -365,6 +368,7 @@ public class DiskBackedPartitionStore<I extends WritableComparable,
partitionStore.getPartitionEdgeCount(partitionId));
Partition<I, V, E> partition =
partitionStore.removePartition(partitionId);
+ LOG.debug("Offloading partition " + partition + " DataIndex[" + index + "]");
index.addIndex(DataIndex.TypeIndexEntry.PARTITION_VERTICES);
OutOfCoreDataAccessor.DataOutputWrapper outputWrapper =
dataAccessor.prepareOutput(ioThreadId, index.copy(), false);