Skip to content

Commit b22c776

Browse files
committed
Fix k8s client class in SparkSubmit
1 parent 4c3f966 commit b22c776

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ object SparkSubmit extends CommandLineUtils with Logging {
9999
private[deploy] val REST_CLUSTER_SUBMIT_CLASS = classOf[RestSubmissionClientApp].getName()
100100
private[deploy] val STANDALONE_CLUSTER_SUBMIT_CLASS = classOf[ClientApp].getName()
101101
private[deploy] val KUBERNETES_CLUSTER_SUBMIT_CLASS =
102-
"org.apache.spark.deploy.k8s.submit.KubernetesClientApplication"
102+
"org.apache.spark.deploy.k8s.submit.Client"
103103

104104
// scalastyle:off println
105105
private[spark] def printVersionAndExit(): Unit = {

0 commit comments

Comments
 (0)