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/02 02:16:44 UTC
git commit: updated refs/heads/trunk to 24309fe
Repository: giraph
Updated Branches:
refs/heads/trunk 6d4af60e7 -> 24309fea6
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/24309fea
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/24309fea
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/24309fea
Branch: refs/heads/trunk
Commit: 24309fea666a7c82b79e17395523ad1b8ee87528
Parents: 6d4af60
Author: Maja Kabiljo <ma...@fb.com>
Authored: Fri Aug 1 17:15:59 2014 -0700
Committer: Maja Kabiljo <ma...@fb.com>
Committed: Fri Aug 1 17:15:59 2014 -0700
----------------------------------------------------------------------
.../org/apache/giraph/aggregators/TestAggregatorsHandling.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/giraph/blob/24309fea/giraph-examples/src/test/java/org/apache/giraph/aggregators/TestAggregatorsHandling.java
----------------------------------------------------------------------
diff --git a/giraph-examples/src/test/java/org/apache/giraph/aggregators/TestAggregatorsHandling.java b/giraph-examples/src/test/java/org/apache/giraph/aggregators/TestAggregatorsHandling.java
index e2b611b..eb3f686 100644
--- a/giraph-examples/src/test/java/org/apache/giraph/aggregators/TestAggregatorsHandling.java
+++ b/giraph-examples/src/test/java/org/apache/giraph/aggregators/TestAggregatorsHandling.java
@@ -129,8 +129,8 @@ public class TestAggregatorsHandling extends BspCase {
AggregatorWrapper<Writable> regularAgg =
getAggregatorMap(restartedHandler).get(regularAggName);
- assertTrue(
- regularAgg.getAggregatorClass().equals(LongSumAggregator.class));
+ assertTrue(regularAgg.getAggregatorFactory().create().getClass().equals(
+ LongSumAggregator.class));
assertEquals(regularValue, regularAgg.getPreviousAggregatedValue());
assertEquals(regularValue,
restartedHandler.<LongWritable>getAggregatedValue(regularAggName));
@@ -138,7 +138,7 @@ public class TestAggregatorsHandling extends BspCase {
AggregatorWrapper<Writable> persistentAgg =
getAggregatorMap(restartedHandler).get(persistentAggName);
- assertTrue(persistentAgg.getAggregatorClass().equals
+ assertTrue(persistentAgg.getAggregatorFactory().create().getClass().equals
(DoubleOverwriteAggregator.class));
assertEquals(persistentValue, persistentAgg.getPreviousAggregatedValue());
assertEquals(persistentValue,