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 <majakabi...@fb.com> Authored: Tue Feb 13 15:42:12 2018 -0800 Committer: Maja Kabiljo <majakabi...@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);
