flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m..@apache.org
Subject flink git commit: [FLINK-3757] clarify JavaDoc for addAccumulator method
Date Sat, 25 Jun 2016 15:39:20 GMT
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 <mxm@apache.org>
Authored: Mon Jun 20 17:45:57 2016 +0200
Committer: Maximilian Michels <mxm@apache.org>
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);
 


Mime
View raw message