Github user fhueske commented on the pull request:
https://github.com/apache/incubator-flink/pull/209#issuecomment-65091843
Thanks for the pull request!
I added some comments in-line.
Could you also add the following tests to the Java and Scala integration
tests:
- KeyExtractor returns a Tuple2 as key
- GroupReduce function is combinable (including the checks that the
elements are processed by the combiner in the right order).
Thank you very much!
---
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.
---
