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
Yeah I think you're right and there is no need for anything, really.
I was thinking of having more user friendly tests for my POJOs for which I
checked the Kryo Fallback and if detected provide an exhaustive list of
issues found (vs raising an exception for the first problem, requiring
users to fi
