Skip to content

Commit 74921c2

Browse files
BryanCutlersrowen
authored andcommitted
[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 <[email protected]> Closes #9255 from BryanCutler/fix-TestClient-classname-SPARK-11287. (cherry picked from commit 80279ac) Signed-off-by: Sean Owen <[email protected]>
1 parent 36fddb0 commit 74921c2

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

core/src/main/scala/org/apache/spark/deploy/client/TestClient.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,8 +48,9 @@ private[spark] object TestClient {
4848
val url = args(0)
4949
val conf = new SparkConf
5050
val rpcEnv = RpcEnv.create("spark", Utils.localHostName(), 0, conf, new SecurityManager(conf))
51+
val executorClassname = TestExecutor.getClass.getCanonicalName.stripSuffix("$")
5152
val desc = new ApplicationDescription("TestClient", Some(1), 512,
52-
Command("spark.deploy.client.TestExecutor", Seq(), Map(), Seq(), Seq(), Seq()), "ignored")
53+
Command(executorClassname, Seq(), Map(), Seq(), Seq(), Seq()), "ignored")
5354
val listener = new TestListener
5455
val client = new AppClient(rpcEnv, Array(url), desc, listener, new SparkConf)
5556
client.start()

0 commit comments

Comments
 (0)