[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Flink Task Allocation on Nodes

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?