[
https://issues.apache.org/jira/browse/FLINK-2998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217621#comment-15217621
]
ASF GitHub Bot commented on FLINK-2998:
---------------------------------------
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1838#issuecomment-203307525
I'm currently on vacation. Will have a closer look when I'm back in about a
week.
I am not sure that we need to touch the Join and CoGroup operators to pass
the distributions. The optimizer is able to get this from the GlobalProperties
to decide whether the partitionings are valid and equivalent.
> Support range partition comparison for multi input nodes.
> ---------------------------------------------------------
>
> Key: FLINK-2998
> URL: https://issues.apache.org/jira/browse/FLINK-2998
> Project: Flink
> Issue Type: New Feature
> Components: Optimizer
> Reporter: Chengxiang Li
> Priority: Minor
>
> The optimizer may have potential opportunity to optimize the DAG while it
> found two input range partition are equivalent, we does not support the
> comparison yet.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
