Skip to content

Commit

Permalink
[SPARK-11287] Fixed class name to properly start TestExecutor from de…
Browse files Browse the repository at this point in the history
…ploy.client.TestClient

Executing deploy.client.TestClient fails due to bad class name for TestExecutor in ApplicationDescription.

Author: Bryan Cutler <bjcutler@us.ibm.com>

Closes #9255 from BryanCutler/fix-TestClient-classname-SPARK-11287.
  • Loading branch information
BryanCutler authored and srowen committed Oct 25, 2015
1 parent 92b9c5e commit 80279ac
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -48,8 +48,9 @@ private[spark] object TestClient {
val url = args(0)
val conf = new SparkConf
val rpcEnv = RpcEnv.create("spark", Utils.localHostName(), 0, conf, new SecurityManager(conf))
val executorClassname = TestExecutor.getClass.getCanonicalName.stripSuffix("$")
val desc = new ApplicationDescription("TestClient", Some(1), 512,
Command("spark.deploy.client.TestExecutor", Seq(), Map(), Seq(), Seq(), Seq()), "ignored")
Command(executorClassname, Seq(), Map(), Seq(), Seq(), Seq()), "ignored")
val listener = new TestListener
val client = new AppClient(rpcEnv, Array(url), desc, listener, new SparkConf)
client.start()
Expand Down

0 comments on commit 80279ac

Please sign in to comment.