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.
