Hi, it is not restricting the parallelism of your job. Only increasing the parallelism of your Job’s sources to more than 5 will not bring any improvements. All other operators could still benefit from a higher parallelism.
> Am 30.05.2017 um 09:49 schrieb Moiz S Jinia <moiz.ji...@gmail.com>: > > For a keyed stream (where the key is also the message key in the source kafka > topic), is the parallelism of the job restricted to the number of partitions > in the topic? > > Source topic has 5 partitions, but available task slots are 12. (3 task > managers each with 4 slots) > > Moiz
