Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-216226071
There is no way to get the aggregated value of the current superstep, as
the aggregation happens at the superstep barrier. What you could do is
normalize the vertex value in the `MessagingFunction` of the next superstep.
E.g. say in superstep `i` you need to set each vertex value to `v / sum(i)`.
You can instead set it to `v` and then propagate `v / sum(i)` in the scatter
phase of superstep `i+1`. Would that work?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
