Hi, I have the simplest streaming job, and I want to distribute my job on every node of my Flink cluster.
Job is simple: source (SocketTextStream) -> map -> sink (AsyncHtttpSink). When I increase parallelism of my job when deploying or directly in code, no effect because source is can't work in parallel. Now I reduce "Tasks Slots" to 1 on ever nodes and deploy my job as many times as nodes in the cluster. It works when I have only one job. If I want deploy another in parallel there is no free slots. I hope more convenient way to do that is exists. Thanks. BR, Evgeny
