flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ufuk Celebi <...@apache.org>
Subject Reduce combiner not chained
Date Fri, 19 Jun 2015 11:04:17 GMT
Hey all,

on the current master 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.

The corresponding issue is here: https://issues.apache.org/jira/browse/FLINK-2246

Can someone please confirm this? If it is an issue, we should fix it soon. The serialization
overhead is noticeable on larger inputs.

– Ufuk
View raw message