Hello there, I have a question about connected streams, I have a data stream of events (A) which needs additional mappings from a stream of events (B). However the streams A might need an event from B which has not been produced yet ( the inverse is also true ) and might be produced in x hours, days, weeks. They both have a shared key I can use to match the corresponding events My solution is to connect stream B to stream A then using a RichCoFlatMapFunction to hold the events of type A or B until I have an event of each to produce the mapping. Does this solution ensures that all events no matter how far appart will be indeed processed? ( I did not set any windowing )?