Hi
Because flink use lazy evaluation and because inactivityCEP don't have any
output then you pattern not apply.
/
inactivityCEP.select(new PatternSelectFunction<ObservationEvent, Object>() {
@Override
public Object select(Map<String, ObservationEvent> pattern) throws
Exception {
System.out.println(pattern);
return null;
}
});
/
>> What am I missing
you missing output ;)
2017-01-07 22:47 GMT+04:00 madhairsilence <harish.kum...@tcs.com>:
> Anybody?. Got kinda stuck here :(
>
>
>
> --
> View this message in context: http://apache-flink-mailing-
> list-archive.1008284.n3.nabble.com/DataStream-and-CEP-
> Pattern-not-matching-after-applying-a-window-tp15164p15173.html
> Sent from the Apache Flink Mailing List archive. mailing list archive at
> Nabble.com.
>
