我在用Flink Cep的时候发现,flatSelect,Select和process算子不能设置并行度,并行度只能是1.我的数据流是根据userId进行keyby,然后匹配每个用户的行为,如果并行度是1的话,那么多个用户的数据就会混在一起,无法通过规则判断,请问Cep的算子如何增加并行度,或者有没有其他解决办法?
https://www.cnblogs.com/weiyiming007/p/11263544.html