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

Reply via email to