I have found two off-by-one issues in the windowing code. The first may result in duplicate data in the last window and is easy to fix. [1]
The second may result data being swallowed in the last window, and is also not difficult to fix. [2] I've talked to Aljoscha about fixing the second one, and he suggested not to fix it right away as that part should be rewritten soon anyways, maybe we remove that functionality as a whole. As this is also in the 0.9.0 release I would still opt for having it, at least for the sake of 0.9.1. What do you think? [1] https://issues.apache.org/jira/browse/FLINK-2285 [2] https://issues.apache.org/jira/browse/FLINK-2286 Best, Marton
