Re: DataStream and CEP - Pattern not matching after applying a window

2017-01-08 Thread madhairsilence
Hi..Thanks for the reply. I can see the pattern is not getting data. So what correct I have to do. I want to apply the pattern only after the window function is executed. Sorry to say, I could hardly get any info from the documentation. -- View this message in context: http://apache-flink-m

Re: DataStream and CEP - Pattern not matching after applying a window

2017-01-08 Thread Alexey Demin
Hi Because flink use lazy evaluation and because inactivityCEP don't have any output then you pattern not apply. / inactivityCEP.select(new PatternSelectFunction() { @Override public Object select(Map pattern) throws Exception { System.out.println(pattern); return null; } }); / >> What am I mis