commit 94a3ac5fbd184bde121f94895a5bdf22cf034d70
author Maja Kabiljo <majakabiljo@fb.com> Tue Feb 13 15:42:12 2018 -0800
committer Maja Kabiljo <majakabiljo@fb.com> Tue Feb 13 15:42:43 2018 -0800
tree ce0e65baf6ea94faa846bf6cb040163dde5e640f
parent 14845725ea57e4ff110bc5fd838aabe6e6d20c25

closes #59

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 @@
     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 @@
           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);