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 wrote: > >> Hey David, >

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 - need to get notified of

Re: Listening to timed-out patterns in Flink CEP

2017-04-25 Thread Moiz Jinia
Hey David, Did that work for you? If yes could you share an example. I have a similar use case - need to get notified of an event NOT occurring within a specified time window. Thanks much! Moiz -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.co

Re: Listening to timed-out patterns in Flink CEP

2016-11-11 Thread David Koch
;> autoWatermarkInterval >>>>>>>> (or less to be conservative). >>>>>>>> >>>>>>>> You can check if the watermark has changed since the arrival of the >>>>>>>> last event and if not increment it in the getCurrentWatermark() method. >>>>>>>> Othe

Re: Listening to timed-out patterns in Flink CEP

2016-11-08 Thread Till Rohrmann
gt;>> till.rohrm...@gmail.com> wrote: >>>>>>> >>>>>>>> Hi David, >>>>>>>> >>>>>>>> the problem is still that there is no corresponding watermark >>>>>>>> saying that 4 seconds ha

Re: Listening to timed-out patterns in Flink CEP

2016-10-14 Thread Till Rohrmann
t;>> periodically emitted but the same watermark will be emitted until a new >>>>>>> element arrives which will reset the watermark. Thus, the system can >>>>>>> never >>>>>>> know until this watermark is seen whether there will be an

Re: Listening to timed-out patterns in Flink CEP

2016-10-14 Thread David Koch
;>>>>>> >>>>>>> ---------- >>>>>>> *From:* David Koch >>>>>>> *To:* user@flink.apache.org; lg...@yahoo.com >>>>>>> *Sent:* Sunday, October 9, 2016 5:51 AM >>>>>>> >>>&g

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread Sameer W
t;>>> "not" operator) does not address this because again, how would the "not >>>>>> match" be triggered if no event at all occurs? >>>>>> >>>>>> Good question. >>>>>> >>>&

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread David Koch
gt;>> >>>>> Good question. >>>>> >>>>> I'm not sure whether the following will work: >>>>> >>>>> This could be done by creating a CEP matching pattern that uses both >>>>> of "notNext" (or "notFollowedB

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread Sameer W
EP matching pattern that uses both of >>>> "notNext" (or "notFollowedBy") and "within" constructs. Something like >>>> this: >>>> >>>> Pattern pattern = Pattern.begin("first") >>>> .no

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread David Koch
constructs. Something like >>>> this: >>>> >>>> Pattern pattern = Pattern.begin("first") >>>> .notNext("second") >>>> .within(Time.seconds(3)); >>>> >>>> I'm hoping Flink CEP experts

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread Till Rohrmann
n(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 CEP, but notNext/notFollowedBy are not yet implemented in Flink.. >>>

Re: Listening to timed-out patterns in Flink CEP

2016-10-11 Thread Sameer W
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 >> *To:

Re: Listening to timed-out patterns in Flink CEP

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

Re: Listening to timed-out patterns in Flink CEP

2016-10-09 Thread lgfmt
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 To: user@flink.apache.org; lg...@yahoo.com Sent: Sunday, October 9, 2016 5:51 AM Subject: Re: Listening to timed-out pa

Re: Listening to timed-out patterns in Flink CEP

2016-10-09 Thread David Koch
-DkoGfVC4UAWD6uQwwRgTsE5be8g%40mail.gmail.com%3E > > > - LF > > > > > -- > *From:* "lg...@yahoo.com" > *To:* "user@flink.apache.org" > *Sent:* Friday, October 7, 2016 3:36 PM > > *Subject:* Re: Listening to timed-out patterns in Flink CEP > &

Re: Listening to timed-out patterns in Flink CEP

2016-10-07 Thread lgfmt
016 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-user/201609.mbox/%3CCAC27z%3DOD%2BTq8twBw_1YKni5sWAU3g1S9WDpJw0DUwg

Re: Listening to timed-out patterns in Flink CEP

2016-10-07 Thread lgfmt
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 little bit how you gen

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 e