How are your task managers deploy ?
If you cluster only have one task manager with one slot in each node,
then the job should be spread evenly.
On 10/24/2018 4:35 PM, Sayat Satybaldiyev wrote:
> Is there any way to indicate flink not to allocate all parallel tasks
> on one node? We have a stateless flink job that reading from 10
> partition topic and have a parallelism of 6. Flink job manager
> allocates all 6 parallel operators to one machine, causing all traffic
> from Kafka allocated to only one machine. We have a cluster of 6 nodes
> and ideal to spread one parallel operator to one machine. Is there a
> way to do than in Flink?