[
https://issues.apache.org/jira/browse/FLINK-1015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14057448#comment-14057448
]
Stephan Ewen commented on FLINK-1015:
-------------------------------------
I agree, the reduce is invoked by {{.groupBy(1, 2).reduce(linkageReducer);}},
so it seems correct.
> Wrong execution strategy
> ------------------------
>
> Key: FLINK-1015
> URL: https://issues.apache.org/jira/browse/FLINK-1015
> Project: Flink
> Issue Type: Bug
> Reporter: Bastian Köcher
> Attachments: impro3-ss14-stratosphere.zip
>
>
> We have a min reducer and it's taking really long. It's look like the reducer
> is sorted in each iteration, but we don't need any sorting. We think that
> this is the false execution plan. Here is the printed execution plan:
> http://pastebin.com/cBXsBt6q
--
This message was sent by Atlassian JIRA
(v6.2#6252)
