Repository: flink Updated Branches: refs/heads/release-1.0 37bc3374a -> 9636d684f
[FLINK-3757] clarify JavaDoc for addAccumulator method This closes #2138 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9636d684 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9636d684 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9636d684 Branch: refs/heads/release-1.0 Commit: 9636d684f0de604f6b1a9297b796c75dc70ce212 Parents: 37bc337 Author: Maximilian Michels <[email protected]> Authored: Mon Jun 20 17:45:57 2016 +0200 Committer: Maximilian Michels <[email protected]> Committed: Sat Jun 25 17:40:35 2016 +0200 ---------------------------------------------------------------------- .../org/apache/flink/api/common/functions/RuntimeContext.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/9636d684/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java b/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java index 3225c00..ee256fe 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java @@ -106,7 +106,10 @@ public interface RuntimeContext { // -------------------------------------------------------------------------------------------- /** - * Add this accumulator. Throws an exception if the accumulator already exists. + * Add this accumulator. Throws an exception if the accumulator already exists in the same Task. + * Note that the Accumulator name must have an unique name across the Flink job. Otherwise you will + * get an error when incompatible accumulators from different Tasks are combined at the JobManager + * upon job completion. */ <V, A extends Serializable> void addAccumulator(String name, Accumulator<V, A> accumulator);
