Updated Branches: refs/heads/trunk 482b7ccb5 -> 345b3d965
GIRAPH-721: Don't call progress on each edge/vertex loaded (majakabiljo) Project: http://git-wip-us.apache.org/repos/asf/giraph/repo Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/345b3d96 Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/345b3d96 Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/345b3d96 Branch: refs/heads/trunk Commit: 345b3d965d42efeafa0b2e7dba2a505c1fa1d771 Parents: 482b7cc Author: Maja Kabiljo <[email protected]> Authored: Fri Jul 19 09:35:14 2013 -0700 Committer: Maja Kabiljo <[email protected]> Committed: Fri Jul 19 09:35:14 2013 -0700 ---------------------------------------------------------------------- CHANGELOG | 2 ++ .../java/org/apache/giraph/worker/EdgeInputSplitsCallable.java | 1 - .../java/org/apache/giraph/worker/VertexInputSplitsCallable.java | 1 - 3 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/giraph/blob/345b3d96/CHANGELOG ---------------------------------------------------------------------- diff --git a/CHANGELOG b/CHANGELOG index 74c9c29..3539a00 100644 --- a/CHANGELOG +++ b/CHANGELOG @@ -1,6 +1,8 @@ Giraph Change Log Release 1.1.0 - unreleased + GIRAPH-721: Don't call progress on each edge/vertex loaded (majakabiljo) + GIRAPH-720: Provide a way to change job name (majakabiljo) GIRAPH-718: Output all per-superstep metrics per superstep (majakabiljo) http://git-wip-us.apache.org/repos/asf/giraph/blob/345b3d96/giraph-core/src/main/java/org/apache/giraph/worker/EdgeInputSplitsCallable.java ---------------------------------------------------------------------- diff --git a/giraph-core/src/main/java/org/apache/giraph/worker/EdgeInputSplitsCallable.java b/giraph-core/src/main/java/org/apache/giraph/worker/EdgeInputSplitsCallable.java index c2c72c6..8ec0453 100644 --- a/giraph-core/src/main/java/org/apache/giraph/worker/EdgeInputSplitsCallable.java +++ b/giraph-core/src/main/java/org/apache/giraph/worker/EdgeInputSplitsCallable.java @@ -170,7 +170,6 @@ public class EdgeInputSplitsCallable<I extends WritableComparable, } workerClientRequestProcessor.sendEdgeRequest(sourceId, readerEdge); - context.progress(); // do this before potential data transfer // Update status every EDGES_UPDATE_PERIOD edges if (inputSplitEdgesLoaded % EDGES_UPDATE_PERIOD == 0) { http://git-wip-us.apache.org/repos/asf/giraph/blob/345b3d96/giraph-core/src/main/java/org/apache/giraph/worker/VertexInputSplitsCallable.java ---------------------------------------------------------------------- diff --git a/giraph-core/src/main/java/org/apache/giraph/worker/VertexInputSplitsCallable.java b/giraph-core/src/main/java/org/apache/giraph/worker/VertexInputSplitsCallable.java index fb4fdf4..01a6fc5 100644 --- a/giraph-core/src/main/java/org/apache/giraph/worker/VertexInputSplitsCallable.java +++ b/giraph-core/src/main/java/org/apache/giraph/worker/VertexInputSplitsCallable.java @@ -171,7 +171,6 @@ public class VertexInputSplitsCallable<I extends WritableComparable, bspServiceWorker.getVertexPartitionOwner(readerVertex.getId()); workerClientRequestProcessor.sendVertexRequest( partitionOwner, readerVertex); - context.progress(); // do this before potential data transfer edgesSinceLastUpdate += readerVertex.getNumEdges(); // Update status every VERTICES_UPDATE_PERIOD vertices
