Re: Queries regarding FlinkCEP

Posted by Biplob Biswas on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Queries-regarding-FlinkCEP-tp13454p13509.html

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