Hi Fabian,
It does not since my events are out of order within a certain interval and
removing allowedLateness reduces the elements processed with 99.5%.
Is it possible to trigger the window first when the allowed latness value
has been passed?
Regards
Björn Zachrisson
On 16 February 2018
Hi,
I have a question regarding timing of events.
According to;
https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/event_time.html#event-time-and-watermarks
All events up to and equal to watermark should be handled in "the prevoius
window".
In my case I use event-timestamp.
I'm
Hi,
According to the link https://pastebin.com/409Z0tSc
I'm trying to start building my flink application based on "taxi
drives"-example.
I use a priority queue to add the events and emitting watermarks every
period+1min where period normally is 30minutes.
The thing is that the events seems to
