Spark on Yarn - How to run multiple tasks in a Spark Resource Pool

Question

Hi,

I am running Spark jobs on YARN, using HDP 3.1.1.0-78 version.

I have set the Spark Scheduler Mode to FAIR by setting the parameter "spark.scheduler.mode" to FAIR. The fairscheduler.xml is as follows:

I have also configured my program to use "production" pool.

Upon running the job, it has been observed that although 4 stages are running, only 1 stage run under "production" and rest 3 run under "default" pool.

So, at any point of time, I am able to make sure that only 2 tasks are running in parallel. If I want to make sure that 3 tasks or more run in parallel, then 2 tasks should run under "production" and rest 2 should run under "default".

Is there any programmatic way to achieve that, by setting configuration parameters?

Any inputs will be really helpful.

Thanks and Regards,

Sudhindra

ssk26 · Accepted Answer

I have observed that by increasing the number of cores/executors and driver/executor memory, I was able to verify that around 6 tasks are running in parallel at a time.  Thanks and Regards, Sudhindra

ssk26 · Answer

Additional Information:As we can see, even though there are 3 stages active, only 1 task each is running in Production as well as Default pools.  My basic question is - how can we increase the parallelism within pools?  In other words, how can I make sure that the Stage ID "8" in the above screenshot also runs in parallel with the other 2  Thanks and Regards,Sudhindra

Sign up

Please use your Cloudera account.

Login to the community

Please use your Cloudera account.