GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/464
[FLINK-1652] fixes superstep increment in CollectionExecutor
- The superstep number was not properly incremented and passed
toVertexCentricIteration used in Spargel and Gelly, in Collection mode.
- See also the [relevant mailing list thread]
(https://mail-archives.apache.org/mod_mbox/flink-dev/201503.mbox/ajax/%3CCAK5ODX4YiNqqSXAYrK0PAwvEDYm%2Bjakvvu8%3Dvup62H4Vwc_uMQ%40mail.gmail.com%3E).
I'm not sure that this is the proper way to do this. I was actually a bit
confused regarding how the runtime contexts are created and set inside the
CollectionExecutor. Input is welcome!
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vasia/flink superstep-in-collection-mode
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/464.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #464
----
commit fa1919aa7ff93d0bc94dd7628afcc46b47b7c7e9
Author: vasia <[email protected]>
Date: 2015-03-08T23:11:20Z
[FLINK-1652] fixes superstep increment in CollectionExecutor
----
---
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.
---
