[SPARK-3560] Fixed setting spark.jars system property in yarn-cluster mode
Author: Victsm <victor.nju@gmail.com>
Author: Min Shen <mshen@linkedin.com>
Closes #2449 from Victsm/SPARK-3560 and squashes the following commits:
918405a [Victsm] Removed the additional space
4502a2a [Min Shen] [SPARK-3560] Fixed setting spark.jars system property in yarn-cluster mode.
(cherry picked from commit 832dff64dd
)
Signed-off-by: Andrew Or <andrewor14@gmail.com>
This commit is contained in:
parent
471e6a3a47
commit
b3ed37e5ba
|
@ -172,7 +172,7 @@ object SparkSubmit {
|
|||
// All cluster managers
|
||||
OptionAssigner(args.master, ALL_CLUSTER_MGRS, ALL_DEPLOY_MODES, sysProp = "spark.master"),
|
||||
OptionAssigner(args.name, ALL_CLUSTER_MGRS, ALL_DEPLOY_MODES, sysProp = "spark.app.name"),
|
||||
OptionAssigner(args.jars, ALL_CLUSTER_MGRS, ALL_DEPLOY_MODES, sysProp = "spark.jars"),
|
||||
OptionAssigner(args.jars, ALL_CLUSTER_MGRS, CLIENT, sysProp = "spark.jars"),
|
||||
OptionAssigner(args.driverMemory, ALL_CLUSTER_MGRS, CLIENT,
|
||||
sysProp = "spark.driver.memory"),
|
||||
OptionAssigner(args.driverExtraClassPath, ALL_CLUSTER_MGRS, ALL_DEPLOY_MODES,
|
||||
|
@ -205,6 +205,7 @@ object SparkSubmit {
|
|||
OptionAssigner(args.jars, YARN, CLUSTER, clOption = "--addJars"),
|
||||
|
||||
// Other options
|
||||
OptionAssigner(args.jars, STANDALONE, CLUSTER, sysProp = "spark.jars"),
|
||||
OptionAssigner(args.executorMemory, STANDALONE | MESOS | YARN, ALL_DEPLOY_MODES,
|
||||
sysProp = "spark.executor.memory"),
|
||||
OptionAssigner(args.totalExecutorCores, STANDALONE | MESOS, ALL_DEPLOY_MODES,
|
||||
|
|
|
@ -154,6 +154,7 @@ class SparkSubmitSuite extends FunSuite with Matchers {
|
|||
sysProps("spark.app.name") should be ("beauty")
|
||||
sysProps("spark.shuffle.spill") should be ("false")
|
||||
sysProps("SPARK_SUBMIT") should be ("true")
|
||||
sysProps.keys should not contain ("spark.jars")
|
||||
}
|
||||
|
||||
test("handles YARN client mode") {
|
||||
|
|
Loading…
Reference in a new issue