Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[FLINK-3757] clarify JavaDoc for addAccumulator method #2138

Closed
wants to merge 1 commit into from

Conversation

mxm
Copy link
Contributor

@mxm mxm commented Jun 20, 2016

No description provided.

@knaufk
Copy link
Contributor

knaufk commented Jun 20, 2016

What about:

Add this accumulator. Throws an exception if the accumulator already exists in the same Task.
Note that the namespace of Accumulators is scoped to the Flink Job, and adding multiple accumulators with the same name across Tasks will still lead to unexpected behaviour.

@asfgit asfgit closed this in 9c15406 Jun 24, 2016
@mxm
Copy link
Contributor Author

mxm commented Jun 25, 2016

Thank you for the suggestion. I incorporated it!

asfgit pushed a commit that referenced this pull request Jun 25, 2016
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants