Pawel Szczur created BEAM-315:
---------------------------------
Summary: GroupByKey/CoGroupByKey doesn't group correctly with
FlinkPipelineRunner
Key: BEAM-315
URL: https://issues.apache.org/jira/browse/BEAM-315
Project: Beam
Issue Type: Bug
Components: runner-flink
Affects Versions: 0.1.0-incubating
Reporter: Pawel Szczur
Same keys is processed multiple times.
A repo to reproduce the bug:
https://github.com/orian/cogroup-wrong-grouping
Discussion:
http://mail-archives.apache.org/mod_mbox/incubator-beam-user/201605.mbox/%3CCAB2uKkG2xHsWpLFUkYnt8eEzdxU%3DB_nu6crTwVi-ZuUpugxkPQ%40mail.gmail.com%3E
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
