Skip to content

Commit 1048549

Browse files
committed
remove Utils.resolveURIs
1 parent 871f1db commit 1048549

File tree

2 files changed

+1
-5
lines changed

2 files changed

+1
-5
lines changed

core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -104,8 +104,7 @@ private[spark] class SparkSubmitArguments(args: Seq[String]) {
104104
totalExecutorCores = Option(totalExecutorCores)
105105
.getOrElse(defaultProperties.get("spark.cores.max").orNull)
106106
name = Option(name).getOrElse(defaultProperties.get("spark.app.name").orNull)
107-
jars = Option(jars).getOrElse(defaultProperties.get("spark.jars").
108-
map(p => Utils.resolveURIs(p)).orNull)
107+
jars = Option(jars).getOrElse(defaultProperties.get("spark.jars").orNull)
109108

110109
// This supports env vars in older versions of Spark
111110
master = Option(master).getOrElse(System.getenv("MASTER"))

yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientArguments.scala

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -45,10 +45,7 @@ class ClientArguments(val args: Array[String], val sparkConf: SparkConf) {
4545
parseArgs(args.toList)
4646

4747
files = Option(files).getOrElse(sparkConf.getOption("spark.yarn.dist.files").orNull)
48-
files = Option(files).map(p => Utils.resolveURIs(p)).orNull
49-
5048
archives = Option(archives).getOrElse(sparkConf.getOption("spark.yarn.dist.archives").orNull)
51-
archives = Option(archives).map(p => Utils.resolveURIs(p)).orNull
5249

5350
private def parseArgs(inputArgs: List[String]): Unit = {
5451
val userArgsBuffer: ArrayBuffer[String] = new ArrayBuffer[String]()

0 commit comments

Comments
 (0)