提交 9c154064 编写于 作者: M Maximilian Michels

[FLINK-3757] clarify JavaDoc for addAccumulator method

This closes #2138
上级 dfecca77
......@@ -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);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册