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 <dlogothe...@gmail.com> Authored: Tue Mar 13 15:17:12 2018 -0700 Committer: Maja Kabiljo <majakabi...@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);
