We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e627adc commit ac3ffcfCopy full SHA for ac3ffcf
yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala
@@ -1193,10 +1193,10 @@ object Client extends Logging {
1193
}
1194
1195
private def getMainJarUri(mainJar: Option[String]): Option[URI] = {
1196
- mainJar.flatMap { path =
+ mainJar.flatMap { path =>
1197
val uri = new URI(path)
1198
if (uri.getScheme == LOCAL_SCHEME) Some(uri) else None
1199
- }.orElse(Some(new URI(APP_JAR)))
+ }.orElse(Some(new URI(APP_JAR)))
1200
1201
1202
private def getSecondaryJarUris(secondaryJars: Option[String]): Seq[URI] = {
0 commit comments