git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Flink join stream where one stream is coming 5 minutes late


May I ask why you want to have 2 differences between window time? What's the use case?

On Mon 26 Nov, 2018, 5:53 PM Abhijeet Kumar <abhijeet.kumar@xxxxxxxxxxxx wrote:
Hello Team,

I've to join two stream where one stream is coming late. So, I planned doing it by creating two windows, for first window the size will be 5 minutes and for the other it will be 10 minutes. Then, I'll perform the join operation. Is my solution correct because I don't know whether one window will sync with other or not because one is getting finished earlier and another is late. If there is a better way to achieve the same, please let me know. 

Thanks,


Abhijeet Kumar
Software Development Engineer,
Sentienz Solutions Pvt Ltd
Cognitive Data Platform - Perceive the Data !