question Re: Spark on Yarn - How to run multiple tasks in a Spark Resource Pool in Support Questions

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

ssk26 — Tue, 07 Jan 2020 06:49:25 GMT

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

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

ssk26 — Tue, 07 Jan 2020 06:15:11 GMT

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

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

ssk26 — Tue, 07 Jan 2020 09:29:07 GMT

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