Re: Flink job parallelism

2019-08-16 Thread Biao Liu
Hi Vishwas, Regardless of the available task manager, what's your job really look like? Is it with parallelism 2 or 1? It's hard to say what happened based on your description. Could you reproduce the scenario? If the answer is yes, then could you provide more details? Like a screenshot, logs,

Flink job parallelism

2019-08-15 Thread Vishwas Siravara
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.