Whether using KeyedStream depends on the logic of your job, i.e, whether you are looking for patterns for some partitions, i.e, patterns for a particular user. If so, you should partition the input data before the CEP operator. Otherwise, the input data should not be partitioned.
Regards, Dian > 在 2019年1月24日，下午12:37，dhanuka ranasinghe <dhanuka.priyan...@gmail.com> 写道： > > 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 > <mailto: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 > > <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 > > <mailto: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. >
