Hi, In 1.5.1 I have noticed some strange behaviour that happens quite frequently and I just want to double check with you that this is intended.
If I have a non-parallel source that takes the following actions: emit: event1 emit: watermark1 emit: event2 it can happen that a downstream operators receives watermark1 after event2. It doesn't happen very often but definitely seems to happen sometimes. Maybe this is a property of the broadcastEmit(..) method but it seems a little funny :) Thanks for the clarification! Gyula