If I have a standalone cluster running flink, what is the best way to
ingest multiple streams of the same type of data?
For example, if I open a socket text stream, does the socket only get
opened on the master node and then the stream is partitioned out to the
worker nodes?
DataStream<String> text = env.socketTextStream("localhost", port, "\n");
Is it possible to have each worker node be a sensor that receives a stream
of data, where each stream is of the same type (e.g. a series of tuples)?
Thanks
