You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by ap...@apache.org on 2012/08/21 20:59:23 UTC
svn commit: r1375717 - in /giraph/trunk: CHANGELOG
src/main/java/org/apache/giraph/graph/BspServiceMaster.java
Author: apresta
Date: Tue Aug 21 18:59:22 2012
New Revision: 1375717
URL: http://svn.apache.org/viewvc?rev=1375717&view=rev
Log:
GIRAPH-309: Message count is wrong. (aching via apresta)
Modified:
giraph/trunk/CHANGELOG
giraph/trunk/src/main/java/org/apache/giraph/graph/BspServiceMaster.java
Modified: giraph/trunk/CHANGELOG
URL: http://svn.apache.org/viewvc/giraph/trunk/CHANGELOG?rev=1375717&r1=1375716&r2=1375717&view=diff
==============================================================================
--- giraph/trunk/CHANGELOG (original)
+++ giraph/trunk/CHANGELOG Tue Aug 21 18:59:22 2012
@@ -2,6 +2,8 @@ Giraph Change Log
Release 0.2.0 - unreleased
+ GIRAPH-309: Message count is wrong. (aching via apresta)
+
GIRAPH-246: Periodic worker calls to context.progress() will prevent
timeout on some Hadoop clusters during barrier waits. (Eli Reisman
via aching)
Modified: giraph/trunk/src/main/java/org/apache/giraph/graph/BspServiceMaster.java
URL: http://svn.apache.org/viewvc/giraph/trunk/src/main/java/org/apache/giraph/graph/BspServiceMaster.java?rev=1375717&r1=1375716&r2=1375717&view=diff
==============================================================================
--- giraph/trunk/src/main/java/org/apache/giraph/graph/BspServiceMaster.java (original)
+++ giraph/trunk/src/main/java/org/apache/giraph/graph/BspServiceMaster.java Tue Aug 21 18:59:22 2012
@@ -848,11 +848,11 @@ public class BspServiceMaster<I extends
getConfiguration());
for (Writable writable : writableList) {
globalStats.addPartitionStats((PartitionStats) writable);
- globalStats.addMessageCount(
- workerFinishedInfoObj.getLong(
- JSONOBJ_NUM_MESSAGES_KEY));
allPartitionStatsList.add((PartitionStats) writable);
}
+ globalStats.addMessageCount(
+ workerFinishedInfoObj.getLong(
+ JSONOBJ_NUM_MESSAGES_KEY));
} catch (JSONException e) {
throw new IllegalStateException(
"aggregateWorkerStats: JSONException", e);