Hi,
I'm not sure if I fully understood your question. The number of input
sources is always less or equal to the number of slots in one node.
Usually source instances are equally distributed among the parallel workers
(TaskManagers). Maybe this document describing the deployment model is also
help
Hi,
I recognized that, if the number of data input sources are less than or
equal to number of slots in one node, they (input source operators) are all
deployed in the same node. What is the logic behind this? Can't this be a
bottleneck for throughput and distribution of input sources?
Thanks
Ad
