GitHub user StephanEwen opened a pull request:
https://github.com/apache/incubator-flink/pull/223
[FLINK-1263] [optimizer] Implement compatibility checks for binary
operators and custom partitioning
This enhances the optimizer to reuse custom partitionings (created via
groupinga and partition operations) in joins, if the same custom partitioning
is used on both input data sets.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StephanEwen/incubator-flink binarycustom
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-flink/pull/223.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 #223
----
commit 2ffd90bce5b1de9d6f5b8038ddcbd7c543f10f7e
Author: Stephan Ewen <[email protected]>
Date: 2014-11-20T14:25:21Z
[APIs] Enhance test coverage for CollectionInputFormat and add tests for
failed serializations of user code objects
commit 69a54ebb759e44cca52b0065bdb2aab621cbc30e
Author: Stephan Ewen <[email protected]>
Date: 2014-11-20T15:09:40Z
[FLINK-1263] [optimizer] Implement compatibility checks for binary
operators and custom partitioning
----
---
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.
---
