Fix class not found error

andrewor14 · andrewor14 · commit a0ad1e9f778a · 2014-09-16T20:29:34.000-07:00
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
@@ -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))

Original file line number	Diff line number	Diff line change
`@@ -361,9 +361,9 @@ private[spark] trait ClientBase extends Logging {`
`361`	`361`	`}`
`362`	`362`	`val amClass =`
`363`	`363`	`if (isLaunchingDriver) {`
`364`		`- Utils.getFormattedClassName(ApplicationMaster)`
	`364`	`+ Class.forName("org.apache.spark.deploy.yarn.ApplicationMaster").getName`
`365`	`365`	`} else {`
`366`		`- Utils.getFormattedClassName(ExecutorLauncher)`
	`366`	`+ Class.forName("org.apache.spark.deploy.yarn.ExecutorLauncher").getName`
`367`	`367`	`}`
`368`	`368`	`val userArgs = args.userArgs.flatMap { arg =>`
`369`	`369`	`Seq("--arg", YarnSparkHadoopUtil.escapeForShell(arg))`