You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by ma...@apache.org on 2014/08/04 22:57:48 UTC
git commit: updated refs/heads/trunk to d455270
Repository: giraph
Updated Branches:
refs/heads/trunk 24309fea6 -> d455270e2
Fix GIRAPH-934
Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/d455270e
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/d455270e
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/d455270e
Branch: refs/heads/trunk
Commit: d455270e2a8d5ec34d63d20ccb0f99d3629efa5e
Parents: 24309fe
Author: Maja Kabiljo <ma...@fb.com>
Authored: Mon Aug 4 13:46:51 2014 -0700
Committer: Maja Kabiljo <ma...@fb.com>
Committed: Mon Aug 4 13:46:51 2014 -0700
----------------------------------------------------------------------
.../java/org/apache/giraph/master/MasterAggregatorHandler.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/giraph/blob/d455270e/giraph-core/src/main/java/org/apache/giraph/master/MasterAggregatorHandler.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/master/MasterAggregatorHandler.java b/giraph-core/src/main/java/org/apache/giraph/master/MasterAggregatorHandler.java
index 2bc08e9..2b0cdd6 100644
--- a/giraph-core/src/main/java/org/apache/giraph/master/MasterAggregatorHandler.java
+++ b/giraph-core/src/main/java/org/apache/giraph/master/MasterAggregatorHandler.java
@@ -337,7 +337,8 @@ public class MasterAggregatorHandler implements MasterAggregatorUsage,
for (Map.Entry<String, AggregatorWrapper<Writable>> entry :
aggregatorMap.entrySet()) {
out.writeUTF(entry.getKey());
- entry.getValue().getAggregatorFactory().write(out);
+ WritableUtils.writeWritableObject(
+ entry.getValue().getAggregatorFactory(), out);
out.writeBoolean(entry.getValue().isPersistent());
entry.getValue().getPreviousAggregatedValue().write(out);
progressable.progress();