You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2015/10/25 20:05:50 UTC
spark git commit: [SPARK-11287] Fixed class name to properly start
TestExecutor from deploy.client.TestClient
Repository: spark
Updated Branches:
refs/heads/master 92b9c5edd -> 80279ac18
[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 <bj...@us.ibm.com>
Closes #9255 from BryanCutler/fix-TestClient-classname-SPARK-11287.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/80279ac1
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/80279ac1
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/80279ac1
Branch: refs/heads/master
Commit: 80279ac1875d488f7000f352a958a35536bd4c2e
Parents: 92b9c5e
Author: Bryan Cutler <bj...@us.ibm.com>
Authored: Sun Oct 25 19:05:45 2015 +0000
Committer: Sean Owen <so...@cloudera.com>
Committed: Sun Oct 25 19:05:45 2015 +0000
----------------------------------------------------------------------
.../main/scala/org/apache/spark/deploy/client/TestClient.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/80279ac1/core/src/main/scala/org/apache/spark/deploy/client/TestClient.scala
----------------------------------------------------------------------
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 1c79089..adb3f02 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()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org