[ https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Greg Hogan closed FLINK-2246. ----------------------------- Resolution: Implemented Implemented in 0db804b936efd8631f1a08db37753dad7f1f71ea > Add chained combine driver strategy for ReduceFunction > ------------------------------------------------------ > > Key: FLINK-2246 > URL: https://issues.apache.org/jira/browse/FLINK-2246 > Project: Flink > Issue Type: Improvement > Components: Local Runtime > Affects Versions: 0.9, 0.10.0 > Reporter: Ufuk Celebi > Assignee: Gabor Gevay > Priority: Minor > > Running the WordCount example with a text file input/output results and a > manual reduce function (instead of the sum(1)) results in a combiner, which > is not chained. > Replace sum(1) with the following to reproduce and use a text file as input: > {code} > fileOutput = true; > textPath = "..."; > outputPath = "..."; > {code} > {code} > .reduce(new ReduceFunction<Tuple2<String, Integer>>() { > @Override > public Tuple2<String, Integer> reduce(Tuple2<String, Integer> value1, > Tuple2<String, Integer> value2) throws Exception { > return new Tuple2<String, Integer>(value1.f0, value1.f1 + value2.f1); > } > }); > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)