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/03/13 23:14:10 UTC
git commit: updated refs/heads/trunk to d86d0d5
Repository: giraph
Updated Branches:
refs/heads/trunk 39eb2533b -> d86d0d56e
GIRAPH-1175
closes #63
Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/d86d0d56
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/d86d0d56
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/d86d0d56
Branch: refs/heads/trunk
Commit: d86d0d56e363a20ffa1ef48deea045851fc49d91
Parents: 39eb253
Author: Dionysios Logothetis <dl...@gmail.com>
Authored: Tue Mar 13 15:17:12 2018 -0700
Committer: Maja Kabiljo <ma...@fb.com>
Committed: Tue Mar 13 16:13:08 2018 -0700
----------------------------------------------------------------------
.../org/apache/giraph/ooc/data/DiskBackedPartitionStore.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/giraph/blob/d86d0d56/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 5514a4a..70e909d 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,9 +244,11 @@ 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.");
+ if (v == null) {
+ throw new IllegalStateException("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);