Github user markus-h commented on the pull request:
https://github.com/apache/flink/pull/570#issuecomment-89849730
Thanks for your comments!
I will try to revert my formattings. I am used to doing STRG+F while
programming that probably changed the formatting.
I also got rid of the Thread.sleep(). The problem was acutally a different
one. Akka delivered the same response object to threads on the same machine,
but I thought it would be copies. Now I do a hard copy of the response, that
seems to fix the problem.
I am not sure how to test the interaction between IterationHead and JM
though. Is there some similiar testcase that I could use as a basis?
---
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.
---
