Hi, We try to deploy an application with the following “architecture” :
4 kafka sources => 16 maps => 4 kafka sinks, on 4 nodes, with 24 slots (we disabled operator chaining). So we’d like on each node : 1x source => 4x map => 1x sink That way there are no exchanges between different instances of flink and performances would be optimal. But we get (according to the flink GUI and the Host column when looking at the details of each task) : Node 1 : 1 source => 2 map Node 2 : 1 source => 1 map Node 3 : 1 source => 1 map Node 4 : 1 source => 12 maps => 4 sinks (I think no comments are needed ☺) The the Web UI says that there are 24 slots and they are all used but they don’t seem evenly dispatched … How could we make Flink deploy the tasks the way we want ? B.R. Gwen’
