giraph-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r..@apache.org
Subject [21/47] git commit: updated refs/heads/release-1.1 to 4c139ee
Date Sun, 26 Oct 2014 01:22:04 GMT
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 <majakabiljo@fb.com>
Authored: Fri Aug 1 17:15:59 2014 -0700
Committer: Maja Kabiljo <majakabiljo@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,


Mime
View raw message