Thanks for the explanation. That was really stupid mistake from my side. By
the way, I really like the whole idea and API. Really good job!
Regards
Dawid
2015-12-08 12:30 GMT+01:00 Aljoscha Krettek :
> Hi,
> an important concept of the Flink API is that transformations do not
> modify the origin
Hi,
an important concept of the Flink API is that transformations do not modify the
original stream (or dataset) but return a new stream with the modifications in
place. In your example the result of the extractTimestamps() call should be
used for further processing. I attached your source code
Forgot to mention. I've checked it both on 0.10 and current master.
2015-12-07 20:32 GMT+01:00 Dawid Wysakowicz :
> Hi,
>
> I have recently experimented a bit with windowing and event-time mechanism
> in flink and either I do not understand how should it work or there is some
> kind of a bug.
>
>
Hi,
I have recently experimented a bit with windowing and event-time mechanism
in flink and either I do not understand how should it work or there is some
kind of a bug.
I have prepared two Source Functions. One that emits watermark itself and
one that does not, but I have prepared a TimestampExt
