diff --git a/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientBase.scala b/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientBase.scala index e874ed7e3dada..8dbf6dc6a4819 100644 --- a/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientBase.scala +++ b/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientBase.scala @@ -361,9 +361,9 @@ private[spark] trait ClientBase extends Logging { } val amClass = if (isLaunchingDriver) { - Utils.getFormattedClassName(ApplicationMaster) + Class.forName("org.apache.spark.deploy.yarn.ApplicationMaster").getName } else { - Utils.getFormattedClassName(ExecutorLauncher) + Class.forName("org.apache.spark.deploy.yarn.ExecutorLauncher").getName } val userArgs = args.userArgs.flatMap { arg => Seq("--arg", YarnSparkHadoopUtil.escapeForShell(arg))