Re: [jira] [Created] (FLINK-1986) Group by fails on iterative data streams

2015-05-12 Thread Szabó Péter
The problem is that the the StreamIterationHead is not created, because only IterativeDataStream.transform(...) can create it. groupBy() on an IterativeDataStream does not call transform(), therefore the exception. All methods of DataStream that is supported for iterations and do not call transform

[jira] [Created] (FLINK-1986) Group by fails on iterative data streams

2015-05-07 Thread Daniel Bali (JIRA)
Daniel Bali created FLINK-1986: -- Summary: Group by fails on iterative data streams Key: FLINK-1986 URL: https://issues.apache.org/jira/browse/FLINK-1986 Project: Flink Issue Type: Bug