This repository was archived by the owner on Jan 9, 2020. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +7
-7
lines changed
resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes Expand file tree Collapse file tree 1 file changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -233,13 +233,13 @@ private[spark] class Client(
233233 }
234234
235235 private def submitApplicationToDriverServer (
236- kubernetesClient : KubernetesClient ,
237- driverServiceManager : DriverServiceManager ,
238- sslConfiguration : DriverSubmitSslConfiguration ,
239- driverService : Service ,
240- submitterLocalFiles : Iterable [String ],
241- submitterLocalJars : Iterable [String ],
242- driverPodKubernetesCredentials : KubernetesCredentials ): Unit = {
236+ kubernetesClient : KubernetesClient ,
237+ driverServiceManager : DriverServiceManager ,
238+ sslConfiguration : DriverSubmitSslConfiguration ,
239+ driverService : Service ,
240+ submitterLocalFiles : Iterable [String ],
241+ submitterLocalJars : Iterable [String ],
242+ driverPodKubernetesCredentials : KubernetesCredentials ): Unit = {
243243 sparkConf.getOption(" spark.app.id" ).foreach { id =>
244244 logWarning(s " Warning: Provided app id in spark.app.id as $id will be " +
245245 s " overridden as $kubernetesAppId" )
You can’t perform that action at this time.
0 commit comments