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/release-1.1 Commit: d455270e2a8d5ec34d63d20ccb0f99d3629efa5e Parents: 24309fe Author: Maja Kabiljo <[email protected]> Authored: Mon Aug 4 13:46:51 2014 -0700 Committer: Maja Kabiljo <[email protected]> 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();
