giraph-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m...@apache.org
Subject git commit: updated refs/heads/trunk to 94a3ac5
Date Tue, 13 Feb 2018 23:42:55 GMT
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 <majakabiljo@fb.com>
Authored: Tue Feb 13 15:42:12 2018 -0800
Committer: Maja Kabiljo <majakabiljo@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);


Mime
View raw message