Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-216222300
Hi @gallenvara,
thank you for the PR! I only took a quick look, but I will go through the
changes in detail soon.
One thing I noticed is that you use static variables for performing the
normalization. This won't work in a distributed environment. You will need to
use aggregators instead. Take a look at
`IterationConfiguration.registerAggregator`. `VertexUpdateFunction` and
`MessagingFunction` have methods to retrieve an aggregator and an aggregated
value from the previous superstep. Let me know if you need help :)
---
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.
---
