diff options
| author | Bryan Cutler <bjcutler@us.ibm.com> | 2015-10-25 19:05:45 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-10-25 19:05:45 +0000 |
| commit | 80279ac1875d488f7000f352a958a35536bd4c2e (patch) | |
| tree | bb179708bcc888199de03cb4ff49e7985d0f2316 /core | |
| parent | 92b9c5edd90f7b89efc687c0cea6778daa1a6b66 (diff) | |
| download | spark-80279ac1875d488f7000f352a958a35536bd4c2e.tar.gz spark-80279ac1875d488f7000f352a958a35536bd4c2e.tar.bz2 spark-80279ac1875d488f7000f352a958a35536bd4c2e.zip | |
[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.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/client/TestClient.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/deploy/client/TestClient.scala b/core/src/main/scala/org/apache/spark/deploy/client/TestClient.scala index 1c79089303..adb3f02258 100644 --- a/core/src/main/scala/org/apache/spark/deploy/client/TestClient.scala +++ b/core/src/main/scala/org/apache/spark/deploy/client/TestClient.scala @@ -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() |