Skip to content
Snippets Groups Projects
Commit 80279ac1 authored by Bryan Cutler's avatar Bryan Cutler Committed by Sean Owen
Browse files

[SPARK-11287] Fixed class name to properly start TestExecutor from deploy.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.
parent 92b9c5ed
No related branches found
No related tags found
No related merge requests found
......@@ -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()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment