Thanks a lot, Till and Dawid for such detailed reply. I tried to check and wait what both of you suggested and I still have no events. Thus as pointed out by till, I created a self-contained example to reproduce the issue and the behaviour is the same as was in my original case.
Please find the self-contained example below: https://gist.github.com/revolutionisme/c3878a6420b322176ac686cbf1a8ac43 Also the input to the kafka topic "test" for which it doesn't work is as follows: https://gist.github.com/revolutionisme/3651acf1baa8cf3696019bc92959e1a2 I used only one topic for reproducing the problem although the behaviour is the same when reading from more than one topic. Maybe its a bug, maybe I did something really stupid here. But any help would be really appreciated. Thanks a lot, Biplob -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Queries-regarding-FlinkCEP-tp13454p13509.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
