You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2016/06/24 16:56:08 UTC
[4/6] flink git commit: [FLINK-3757] clarify JavaDoc for
addAccumulator method
[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/9c154064
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9c154064
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9c154064
Branch: refs/heads/master
Commit: 9c15406400af16861be8cf08e60d94074addbba0
Parents: dfecca7
Author: Maximilian Michels <mx...@apache.org>
Authored: Mon Jun 20 17:45:57 2016 +0200
Committer: Maximilian Michels <mx...@apache.org>
Committed: Fri Jun 24 18:53:43 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/9c154064/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 e409c11..a9e8da9 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
@@ -115,7 +115,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);