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/release-1.1 Commit: 24309fea666a7c82b79e17395523ad1b8ee87528 Parents: 6d4af60 Author: Maja Kabiljo <[email protected]> Authored: Fri Aug 1 17:15:59 2014 -0700 Committer: Maja Kabiljo <[email protected]> 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,
