Hi,
Yes it was a watermarking issue. There were few out of order records in my
stream and as per watermarking strategy the watermark was advanced to the
future and hence current events were getting discarded.
I have fixed this by not processing future timestamped records.
Thanks
Sachin
On Mon, A
Hi Sachin
What exactly does the MyReducer do? Can you provide us with some code?
Just a wild guess from my side, did you check the watermarking? If the
Watermarks aren't progressing there's no way for Flink to know when to emit a
window and therefore you won't see any outgoing events.
Kind Reg
