Hi guys, I have a flink job which I want to run with a parallelism of 2. I run it from command line like : flink run -p 2 -C file:///home/was/classpathconfig/ -c com.visa.flink.cli.Main flink-job-assembly-0.1-SNAPSHOT.jar flink druid
My cluster has two task managers with only 1 task slot each. However when I look at the Web UI for my job , I see that one of the task managers is still available. But when I submit with the web UI , both the task managers are used for this job and I get a parallelism of 2. Can you help me with understanding as to why this happens ? Thank you Vishwas
