Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2496
Updated PR. Handles reset()in a much better way. PageRankITCase exposed
some cases. Also does the clean up of the driver now.
Still wondering there should be a reason why the driver was instantiated
every time for an iterative task. May be am missing the reason for that. If
that is for sure needed then this whole fix may not work. But the patch as such
is better in terms of handling the reset() part.
---
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.
---
