Re: Listening to timed-out patterns in Flink CEP

2017-06-13 Thread Till Rohrmann
Great to hear that things are now working :-) On Sun, Jun 11, 2017 at 11:19 PM, David Koch wrote: > Hello, > > It's been a while and I have never replied on the list. In fact, the fix > committed by Till does work. Thanks! > > On Tue, Apr 25, 2017 at 9:37 AM, Moiz Jinia

Re: Listening to timed-out patterns in Flink CEP

2017-06-11 Thread David Koch
Hello, It's been a while and I have never replied on the list. In fact, the fix committed by Till does work. Thanks! On Tue, Apr 25, 2017 at 9:37 AM, Moiz Jinia wrote: > Hey David, > Did that work for you? If yes could you share an example. I have a similar > use case -

Re: Listening to timed-out patterns in Flink CEP

2016-11-11 Thread David Koch
e >>>>>>>> last event and if not increment it in the getCurrentWatermark() method. >>>>>>>> Otherwise the watermark will never increase until an element arrive >>>>>>>> and if >>>>>>>> the stream partition s

Re: Listening to timed-out patterns in Flink CEP

2016-11-08 Thread Till Rohrmann
gt;>> >>>>>>> Sameer >>>>>>> >>>>>>> >>>>>>> On Tue, Oct 11, 2016 at 6:04 AM, Till Rohrmann < >>>>>>> till.rohrm...@gmail.com> wrote: >>>>>>> >>>>>>>> Hi David, >>>>>>>> >>>>>

Re: Listening to timed-out patterns in Flink CEP

2016-10-14 Thread Till Rohrmann
ying >>>>>>> that 4 seconds have now passed. With your code, watermarks will be >>>>>>> periodically emitted but the same watermark will be emitted until a new >>>>>>> element arrives which will reset the watermark. Thus, the system can >>

Re: Listening to timed-out patterns in Flink CEP

2016-10-14 Thread David Koch
t the negation operator won't solve the problem. It >>>>>> will indeed suffer from the same problem. >>>>>> >>>>>> Cheers, >>>>>> Till >>>>>> >>>>>> On Sun, Oct 9, 2016 at 7:37 PM, <lg...@yahoo.c

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread David Koch
one by creating a CEP matching pattern that uses both >>>>> of "notNext" (or "notFollowedBy") and "within" constructs. Something like >>>>> this: >>>>> >>>>> Pattern<Event, ?> pattern = Pattern.begin(&qu

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread Sameer W
gt;>>> Pattern<Event, ?> pattern = Pattern.begin("first") >>>> .notNext("second") >>>> .within(Time.seconds(3)); >>>> >>>> I'm hoping Flink CEP experts (Till?) will comment on this. >>>> >>>>

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread David Koch
at uses both of >>>> "notNext" (or "notFollowedBy") and "within" constructs. Something like >>>> this: >>>> >>>> Pattern<Event, ?> pattern = Pattern.begin("first") >>>> .notNext("second"

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread Till Rohrmann
tern<Event, ?> pattern = Pattern.begin("first") >>> .notNext("second") >>> .within(Time.seconds(3)); >>> >>> I'm hoping Flink CEP experts (Till?) will comment on this. >>> >>> Note: I have requested these negation patterns to be implemented in >>> Flink

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread Sameer W
(Till?) will comment on this. >> >> Note: I have requested these negation patterns to be implemented in Flink >> CEP, but notNext/notFollowedBy are not yet implemented in Flink.. >> >> >> - LF >> >> >> >> >> ---

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread Till Rohrmann
plemented in Flink.. > > > - LF > > > > > ---------- > *From:* David Koch <ogd...@googlemail.com> > *To:* user@flink.apache.org; lg...@yahoo.com > *Sent:* Sunday, October 9, 2016 5:51 AM > > *Subject:* Re: Listening to timed-out p

Re: Listening to timed-out patterns in Flink CEP

2016-10-09 Thread lgfmt
t on this. Note: I have requested these negation patterns to be implemented in Flink CEP, but notNext/notFollowedBy are not yet implemented in Flink.. - LF From: David Koch <ogd...@googlemail.com> To: user@flink.apache.org; lg...@yahoo.com Sent: Sunday, October 9, 2016 5:51 AM Sub

Re: Listening to timed-out patterns in Flink CEP

2016-10-09 Thread David Koch
3-DkoGfVC4UAWD6uQwwRgTsE5be8g%40mail.gmail.com%3E > > > - LF > > > > > -- > *From:* "lg...@yahoo.com" <lg...@yahoo.com> > *To:* "user@flink.apache.org" <user@flink.apache.org> > *Sent:* Friday, October 7, 2016 3:36 PM > >

Re: Listening to timed-out patterns in Flink CEP

2016-10-07 Thread lgfmt
user@flink.apache.org> Sent: Friday, October 7, 2016 3:36 PM Subject: Re: Listening to timed-out patterns in Flink CEP Isn't the upcoming CEP negation (absence of an event) feature solve this issue? See this discussion thread:http://mail-archives.apache.org/mod_mbox/flink

Re: Listening to timed-out patterns in Flink CEP

2016-10-07 Thread lgfmt
hrm...@apache.org> To: user@flink.apache.org Sent: Friday, October 7, 2016 12:58 AM Subject: Re: Listening to timed-out patterns in Flink CEP Hi David, in case of event time, the timeout will be detected when the first watermark exceeding the timeout value is received. Thus, it depends a

Re: Listening to timed-out patterns in Flink CEP

2016-10-07 Thread Till Rohrmann
Hi David, in case of event time, the timeout will be detected when the first watermark exceeding the timeout value is received. Thus, it depends a little bit how you generate watermarks (e.g. periodically, watermark per event). In case of processing time, the time is only updated whenever a new