Re: event time & watermarks in connected streams with broadcast state

2019-02-28 Thread Rinat
Thanks Konstantin ! > On 28 Feb 2019, at 02:33, Konstantin Knauf wrote: > > HI Rinat, > > to my knowledge your workaround is fine & necessary. You can also emit a > Long.MAX_VALUE instead of the processing time to save some CPU cycles. > > Cheers, > > Konstantin > > > > On Wed, Feb 27, 2

Re: event time & watermarks in connected streams with broadcast state

2019-02-27 Thread Konstantin Knauf
HI Rinat, to my knowledge your workaround is fine & necessary. You can also emit a Long.MAX_VALUE instead of the processing time to save some CPU cycles. Cheers, Konstantin On Wed, Feb 27, 2019 at 9:32 PM Rinat wrote: > Hi mates, got some questions about using event time for the flink pipel

event time & watermarks in connected streams with broadcast state

2019-02-27 Thread Rinat
Hi mates, got some questions about using event time for the flink pipeline. My pipeline consists of two connected streams, one is a stream with business rules and another one is a stream with user events. I’ve broadcasted stream with business rules and connected it to the stream of events, thu