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 d86d0d5
Date Tue, 13 Mar 2018 23:14:10 GMT
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 <dlogothetis@gmail.com>
Authored: Tue Mar 13 15:17:12 2018 -0700
Committer: Maja Kabiljo <majakabiljo@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);


Mime
View raw message