You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/06/19 12:54:00 UTC
[jira] [Created] (FLINK-2246) Combiner not chained
Ufuk Celebi created FLINK-2246:
----------------------------------
Summary: Combiner not chained
Key: FLINK-2246
URL: https://issues.apache.org/jira/browse/FLINK-2246
Project: Flink
Issue Type: Bug
Components: Core
Affects Versions: 0.9, master
Reporter: Ufuk Celebi
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)