giraph-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m...@apache.org
Subject git commit: updated refs/heads/trunk to 43de1d8
Date Fri, 16 Jan 2015 18:42:27 GMT
Repository: giraph
Updated Branches:
  refs/heads/trunk 9d20d69fd -> 43de1d8cd


GIRAPH-962: TextAggregatorWriter with frequency AT_THE_END writes in every superstep (mju
via majakabiljo)


Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/43de1d8c
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/43de1d8c
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/43de1d8c

Branch: refs/heads/trunk
Commit: 43de1d8cddacf02e48cf6a7ac5a5888369e978cd
Parents: 9d20d69
Author: Maja Kabiljo <majakabiljo@fb.com>
Authored: Fri Jan 16 10:41:34 2015 -0800
Committer: Maja Kabiljo <majakabiljo@fb.com>
Committed: Fri Jan 16 10:41:34 2015 -0800

----------------------------------------------------------------------
 CHANGELOG                                                         | 2 ++
 .../java/org/apache/giraph/aggregators/TextAggregatorWriter.java  | 3 ++-
 2 files changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/giraph/blob/43de1d8c/CHANGELOG
----------------------------------------------------------------------
diff --git a/CHANGELOG b/CHANGELOG
index 6b5f59f..ad94207 100644
--- a/CHANGELOG
+++ b/CHANGELOG
@@ -1,6 +1,8 @@
 Giraph Change Log
 
 Release 1.2.0 - unreleased
+  GIRAPH-962: TextAggregatorWriter with frequency AT_THE_END writes in every superstep (mju
via majakabiljo)
+
   GIRAPH-967: (Strongly Connected Components) bug fix (mhan via majakabiljo)
  
   GIRAPH-980 Way to disable checkpoints for particular job and on particular supersteps (edunov)

http://git-wip-us.apache.org/repos/asf/giraph/blob/43de1d8c/giraph-core/src/main/java/org/apache/giraph/aggregators/TextAggregatorWriter.java
----------------------------------------------------------------------
diff --git a/giraph-core/src/main/java/org/apache/giraph/aggregators/TextAggregatorWriter.java
b/giraph-core/src/main/java/org/apache/giraph/aggregators/TextAggregatorWriter.java
index 67ce5a4..f9a8d3b 100644
--- a/giraph-core/src/main/java/org/apache/giraph/aggregators/TextAggregatorWriter.java
+++ b/giraph-core/src/main/java/org/apache/giraph/aggregators/TextAggregatorWriter.java
@@ -114,7 +114,8 @@ public class TextAggregatorWriter
    */
   private boolean shouldWrite(long superstep) {
     return (frequency == AT_THE_END && superstep == LAST_SUPERSTEP) ||
-        (frequency != NEVER && superstep % frequency == 0);
+        (frequency != NEVER && frequency != AT_THE_END &&
+            superstep % frequency == 0);
   }
 
   @Override


Mime
View raw message