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.
g-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.
ironment();
> /* 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.
rkInterval(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.
; 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-Alerts-with-FinkCEP-tp1p13401.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at
> Nabble.com.
--
View this 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.
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
using the XSD of the defined event. but i still am not sure how it
changes the way alert is being generated.
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/No-Alerts-with-FinkCEP-tp1p13362.html
Sent from the Apache Flink User Mailing List
nt, endEvent);
>}
> }
>
> but when I am doing it it expects a list from my side for the events:
>
> class MyPatternSelectFunction implements PatternSelectFunction OUT> {
> @Override
> public OUT select(Map> 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.2336050.n4.nabble.com/No-Alerts-with-FinkCEP-tp1p13341.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at
> Nabble.com.
would be really
helpful.
Regards,
Biplob
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/No-Alerts-with-FinkCEP-tp1p13341.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
t; }
>>
>>
>> As my kafka topic only sends me events with formattype = FILE, I was
>> expecting to see multiple alerts being raised. But thats not the case, i am
>> not getting any alert 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.
>
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.
thin 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.
13 matches
Mail list logo