flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Strange behaviour of windows
Date Tue, 08 Dec 2015 11:30:41 GMT
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 with the required modifications.

Other than that, I think you understood the watermarks quite well. :D

Let us know if you need more information.


View raw message