Repository: giraph Updated Branches: refs/heads/trunk 9e1a5a053 -> 441ec8bef
GIRAPH-916: Wrong number of vertices stored reported to command line (majakabiljo) Project: http://git-wip-us.apache.org/repos/asf/giraph/repo Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/441ec8be Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/441ec8be Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/441ec8be Branch: refs/heads/trunk Commit: 441ec8bef03644c9d629f871993c14ff5442409a Parents: 9e1a5a0 Author: Maja Kabiljo <[email protected]> Authored: Tue Jun 24 09:55:28 2014 -0700 Committer: Maja Kabiljo <[email protected]> Committed: Tue Jun 24 09:55:28 2014 -0700 ---------------------------------------------------------------------- CHANGELOG | 2 ++ .../src/main/java/org/apache/giraph/worker/BspServiceWorker.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/giraph/blob/441ec8be/CHANGELOG ---------------------------------------------------------------------- diff --git a/CHANGELOG b/CHANGELOG index 8da555d..2929c66 100644 --- a/CHANGELOG +++ b/CHANGELOG @@ -1,6 +1,8 @@ Giraph Change Log Release 1.1.0 - unreleased + GIRAPH-916: Wrong number of vertices stored reported to command line (majakabiljo) + GIRAPH-919: Add worker to worker communication (majakabiljo) GIRAPH-922: SimpleEdgeStore has a bug causing NPE (pavanka) http://git-wip-us.apache.org/repos/asf/giraph/blob/441ec8be/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 8dcf19a..dbe6a45 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 @@ -1109,7 +1109,7 @@ public class BspServiceWorker<I extends WritableComparable, vertexWriter.setConf(getConfiguration()); vertexWriter.initialize(getContext()); long nextPrintVertices = 0; - long nextUpdateProgressVertices = 0; + long nextUpdateProgressVertices = VERTICES_TO_UPDATE_PROGRESS; long nextPrintMsecs = System.currentTimeMillis() + 15000; int partitionIndex = 0; int numPartitions = getPartitionStore().getNumPartitions();
