Our Community is getting an upgrade! To get everything ready for the relaunch, we’ll be placing the site in read-only mode starting September 21st.
We really appreciate your understanding while we get things set up behind the scenes. Catch up on all the exciting details about the move here.
Need help or have questions? Drop us a line at [email protected]
Created 11-24-2022 06:11 PM
Yarn's application priority can be found in yarn 8088 resource manager's website,
How do the priority work in yarn?
Now the version of CDH I use is 6.3.2.
Hadoop 3.0.0
Hive 2.1.1
I use hive on spark.
Can I use the config to manage the application priority?
For some reason some hive sqls should have high application priority when those sqls are appending and run ahead of the other. Instead of running the same time and equal share the compute resources.
When I set the following config in Hive, it seems do not work well in Yarn.
| MapReduce | "-Dmapreduce.job.priority=xx" |
| Flink | "-yD yarn.applicaiton.priority=xx" |
| Spark | "spark.yarn.priority=xx" |
In hive sql."set spark.yarn.priority=10;"
It does not work ...
Created 11-25-2022 06:09 AM
Hi @bulbcat
- Spark version used in CDH 6.3.2 is Spark 2.4.0 [1]
- Also spark.yarn.priority will only effect from spark-3.0 [2]
[2]https://github.com/apache/spark/pull/27856
If you want to update priority for application during runtime you can use below
yarn application -updatePriority 10 -appId application_xxxx_xx
Thanks!
Created 11-25-2022 06:09 AM
Hi @bulbcat
- Spark version used in CDH 6.3.2 is Spark 2.4.0 [1]
- Also spark.yarn.priority will only effect from spark-3.0 [2]
[2]https://github.com/apache/spark/pull/27856
If you want to update priority for application during runtime you can use below
yarn application -updatePriority 10 -appId application_xxxx_xx
Thanks!
Created 11-28-2022 11:09 PM
Thanks a lot.
This "yarn application -updatePriority 10 -appId application_xxxx_xx"
seems a config of yarn.
It does not work for spark 2.x in CDH 6.3.2 either.
Does it the same reason which means the 'Application Priority' must match the yarn version with spark version?