Hi all, I am using event based processing so i am generating watermark based on event time. I register my event on state using event timestamp. My event is waiting in state for its corresponding record to correlate. Suppose If i am sending 10 records and 10th record having the highest timestamp. Now, this 10th record stays in state until i sent new data with higher timestamp. Is there anything through which we can get that record? Thanks!

Depending on your source, you can consider adding an idle timeout to the watermark strategy

Okay..Thanks!