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.

Reply via email to