Updated Branches: refs/heads/trunk 487ec36fb -> 2f2d80717
GIRAPH-667: all workers suspended at 'saveVertices' when use out of core Project: http://git-wip-us.apache.org/repos/asf/giraph/repo Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/ea957c22 Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/ea957c22 Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/ea957c22 Branch: refs/heads/trunk Commit: ea957c226f07fc4c73bb556bfb51576ce3462ae5 Parents: 3d4f313 Author: Claudio Martella <[email protected]> Authored: Sat Jun 8 20:26:39 2013 +0200 Committer: Claudio Martella <[email protected]> Committed: Sat Jun 8 20:26:39 2013 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/giraph/worker/BspServiceWorker.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/giraph/blob/ea957c22/giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java ---------------------------------------------------------------------- diff --git a/giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java b/giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java index 8b5e39a..eb6d30d 100644 --- a/giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java +++ b/giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java @@ -957,6 +957,7 @@ else[HADOOP_NON_SECURE]*/ nextPrintVertices = verticesWritten + 250000; } } + getPartitionStore().putPartition(partition); ++partitionIndex; } vertexWriter.close(getContext()); // the temp results are saved now
