Hi, events overtaking watermarks doesn’t sound like a „wrong“ behaviour, only watermarks overtaking events would be bad. Do you think this only stated from Flink 1.5? To me this does not sound like a problem, but not sure if it is intended. Looping in Aljoscha, just in case.
Best, Stefan > Am 22.07.2018 um 22:19 schrieb Gyula Fóra <[email protected]>: > > 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
