Hi Dian, I tried that but then kafkaproducer only produce to single partition and only single flink host working while rest not contribute for processing . I will share the code and screenshot
Cheers Dhanuka On Thu, 24 Jan 2019, 12:31 Dian Fu <dian0511...@gmail.com wrote: > Hi Dhanuka, > > In order to make the CEP operator to run parallel, the input stream should > be KeyedStream. You can refer [1] for detailed information. > > Regards, > Dian > > [1]: > https://ci.apache.org/projects/flink/flink-docs-master/dev/libs/cep.html#detecting-patterns > > > 在 2019年1月24日，上午10:18，dhanuka ranasinghe <dhanuka.priyan...@gmail.com> > 写道： > > > > Hi All, > > > > Is there way to run CEP function parallel. Currently CEP run only > sequentially > > > > <flink-CEP.png> > > . > > > > Cheers, > > Dhanuka > > > > -- > > Nothing Impossible,Creativity is more important than knowledge. > >
