Re: No Alerts with FinkCEP

2017-05-31 Thread Biplob Biswas
for the help. Regards, Biplob -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/No-Alerts-with-FinkCEP-tp1p13410.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: No Alerts with FinkCEP

2017-05-31 Thread Biplob Biswas
ling-list-archive.2336050.n4.nabble.com/No-Alerts-with-FinkCEP-tp1p13409.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: No Alerts with FinkCEP

2017-05-31 Thread Kostas Kloudas
nEnvironment.getExecutionEnvironment(); > /* env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); */ > env.getConfig().setAutoWatermarkInterval(1000); > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/No-Alerts-with-FinkCEP-tp1p13405.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.

Re: No Alerts with FinkCEP

2017-05-31 Thread Biplob Biswas
(1000); -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/No-Alerts-with-FinkCEP-tp1p13405.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: No Alerts with FinkCEP

2017-05-31 Thread Kostas Kloudas
ding CEP) > > Thanks a lot for all the Help, I have never been disappointed with the Flink > user Group. :) > > Regards, > Biplob > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/No-Ale

Re: No Alerts with FinkCEP

2017-05-31 Thread Biplob Biswas
is message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/No-Alerts-with-FinkCEP-tp1p13401.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: No Alerts with FinkCEP

2017-05-30 Thread Dawid Wysakowicz
Hi Biplob, The message you mention should not be a problem here. It just says you can't use your events as POJOs (e.g. you can't use keyBy("chargedAccount") ). Your code seems fine and without some example data I think it will be hard to help you. As for the PART 2 of your first email. In 1.3 we

Re: No Alerts with FinkCEP

2017-05-26 Thread Kostas Kloudas
p<String, IN> pattern) { >IN startEvent = pattern.get("start"); >IN endEvent = pattern.get("end"); >return new OUT(startEvent, endEvent); >} > } > > but when I am doing it it expects a list from my side for the events: > >

Re: No Alerts with FinkCEP

2017-05-26 Thread Biplob Biswas
{ @Override public OUT select(Map<String, ListIN>> map) throws Exception { return null; } } Not really sure what am I doing wrong here, any inputs would be really helpful. Regards, Biplob -- View this message in context: http://apache-flink-user-mailing-list-archive.2

Re: No Alerts with FinkCEP

2017-05-26 Thread Kostas Kloudas
S); >> prop.put("zookeeper.connect", ZKEEPER); >> prop.put("auto.offset.reset", "earliest"); >> return prop; >> } >> >> >> As my kafka topic only sends me events with formattype = FILE, I was >> expecting to see

Re: No Alerts with FinkCEP

2017-05-26 Thread Kostas Kloudas
rt at the moment. > > Can anyone point out what am I doing wrong? > > PART 2: > > Also, my main aim for using CEP is to read from different topics and raise > alert if a second event is *not* followed by a first event within a given > time interval. How can I achieve it with FlinkCEP? for now I can only see > that if 2 events follow within a time interval an alert should be raised. > > > Thanks & Regards, > Biplob > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/No-Alerts-with-FinkCEP-tp1.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.

No Alerts with FinkCEP

2017-05-26 Thread Biplob Biswas
given time interval. How can I achieve it with FlinkCEP? for now I can only see that if 2 events follow within a time interval an alert should be raised. Thanks & Regards, Biplob -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/No-Alerts-with-FinkCEP-tp1.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.