[jira] [Commented] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly in batch mode of FlinkPipelineRunner

2016-06-01 Thread Pawel Szczur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15310079#comment-15310079 ] Pawel Szczur commented on BEAM-315: --- Of course, feel free to use it. Super happy I could h

[jira] [Commented] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly in batch mode of FlinkPipelineRunner

2016-06-01 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15309976#comment-15309976 ] Aljoscha Krettek commented on BEAM-315: --- I played around this morning and finally foun

[jira] [Commented] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly in batch mode of FlinkPipelineRunner

2016-05-31 Thread Pawel Szczur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15308901#comment-15308901 ] Pawel Szczur commented on BEAM-315: --- I've found one related bug in Flink itself: https://i

[jira] [Commented] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly in batch mode of FlinkPipelineRunner

2016-05-31 Thread Pawel Szczur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15308890#comment-15308890 ] Pawel Szczur commented on BEAM-315: --- [~frances] Thanks for explanation. The bug appears wi

[jira] [Commented] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly in batch mode of FlinkPipelineRunner

2016-05-31 Thread Frances Perry (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15308245#comment-15308245 ] Frances Perry commented on BEAM-315: The Beam Model (and hence the DataflowRunner) speci

[jira] [Commented] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly in batch mode of FlinkPipelineRunner

2016-05-31 Thread Pawel Szczur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15307958#comment-15307958 ] Pawel Szczur commented on BEAM-315: --- I've tried to set {options.setStreaming(true)} it sea

[jira] [Commented] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly in batch mode of FlinkPipelineRunner

2016-05-31 Thread Pawel Szczur (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15307925#comment-15307925 ] Pawel Szczur commented on BEAM-315: --- I've tried {{options.setStreaming(true)}} it caused:

[jira] [Commented] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly in batch mode of FlinkPipelineRunner

2016-05-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15307853#comment-15307853 ] Maximilian Michels commented on BEAM-315: - It appears this is only a problem in the