[
https://issues.apache.org/jira/browse/FLINK-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371725#comment-14371725
]
Gyula Fora commented on FLINK-1765:
-----------------------------------
This error was introduced today as I enabled chaining for this type of topology
as well. Seems like the collect for GroupReduce was buggy but we never chaimed
that before
> Reducer grouping is skippted when parallelism is one
> ----------------------------------------------------
>
> Key: FLINK-1765
> URL: https://issues.apache.org/jira/browse/FLINK-1765
> Project: Flink
> Issue Type: Bug
> Components: Streaming
> Affects Versions: 0.9
> Reporter: Stephan Ewen
> Fix For: 0.9
>
>
> This program (not the parallelism) incorrectly runs a non grouped reduce and
> fails with a NullPointerException.
> {code}
> StreamExecutionEnvironment env = ...
> env.setDegreeOfParallelism(1);
> DataStream<String> stream = env.addSource(...);
> stream
> .filter(...)
> .map(...)
> .groupBy("someField")
> .reduce(new ReduceFunction() {...} )
> .addSink(...);
> env.execute();
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
