Hello,
we ran a flink application version 1.13.2 that consists of a kafka source with one partition so far then we filter the data based on some conditions, mapped to POJOS and we transform to a KeyedStream based on an accountId long property from the POJO. The downstream operators are 10 CEP operators that run with parallelism of 14 and the maxParallelism is set to the (operatorParallelism * operatorParallelism). As you see in the image attached the events are distributed unevenly so some subtasks are busy and others are idle. Is there any way to distribute evenly the load to the subtasks? Thank you in advance. [image: Capture.PNG]
