From 17c79bbd66708d24c093be5f43e60c61f504d19d Mon Sep 17 00:00:00 2001 From: Andrew Ash Date: Mon, 16 Jun 2014 23:00:19 -0700 Subject: [PATCH] Add a configuration option for spark-shell's class server spark.replClassServer.port --- repl/src/main/scala/org/apache/spark/repl/SparkIMain.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/repl/src/main/scala/org/apache/spark/repl/SparkIMain.scala b/repl/src/main/scala/org/apache/spark/repl/SparkIMain.scala index 3842c291d0b7b..50897a71101f1 100644 --- a/repl/src/main/scala/org/apache/spark/repl/SparkIMain.scala +++ b/repl/src/main/scala/org/apache/spark/repl/SparkIMain.scala @@ -102,7 +102,8 @@ import org.apache.spark.util.Utils val virtualDirectory = new PlainFile(outputDir) // "directory" for classfiles /** Jetty server that will serve our classes to worker nodes */ - val classServer = new HttpServer(outputDir, new SecurityManager(conf)) + val classServerListenPort: Int = conf.getInt("spark.replClassServer.port", 0) + val classServer = new HttpServer(outputDir, new SecurityManager(conf), classServerListenPort) private var currentSettings: Settings = initialSettings var printResults = true // whether to print result lines var totalSilence = false // whether to print anything