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 <[email protected]> Authored: Fri Jan 16 10:41:34 2015 -0800 Committer: Maja Kabiljo <[email protected]> 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
