ibes the situation: https://issues.apache.org/jira/browse/FLINK-4329
> <https://issues.apache.org/jira/browse/FLINK-4329>.
>
> I think this should be fixed for an upcoming 1.1.1 bug fixing release.
>
> Cheers,
> Aljoscha
>
> On Sat, 6 Aug 2016 at 12:33 Adam Warski
hing out.
If I add a .map {x => println(x); x} after .assignAscendingTimestamps I can see
the data flowing - so data *is* being read, just somehow the windowing causes
it to be lost?
Any ideas on where to look for possible causes?
Thanks!
--
Adam Warski
http://twitter.com/#!/adamwarski &
