From fafdf432e3d35c19b07e86ff7ddac23d8298a66e Mon Sep 17 00:00:00 2001 From: jerryshao Date: Tue, 27 Sep 2016 11:44:45 +0800 Subject: [PATCH] Honor spark.replClassServer.port in scala-2.11 repl --- .../src/main/scala/org/apache/spark/repl/Main.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/repl/scala-2.11/src/main/scala/org/apache/spark/repl/Main.scala b/repl/scala-2.11/src/main/scala/org/apache/spark/repl/Main.scala index 627148df80c11..ed4cab06ab86e 100644 --- a/repl/scala-2.11/src/main/scala/org/apache/spark/repl/Main.scala +++ b/repl/scala-2.11/src/main/scala/org/apache/spark/repl/Main.scala @@ -36,7 +36,9 @@ object Main extends Logging { "-Yrepl-outdir", s"${outputDir.getAbsolutePath}", "-classpath", getAddedJars.mkString(File.pathSeparator)), true) // the creation of SecurityManager has to be lazy so SPARK_YARN_MODE is set if needed - lazy val classServer = new HttpServer(conf, outputDir, new SecurityManager(conf)) + val classServerPort = conf.getInt("spark.replClassServer.port", 0) + lazy val classServer = + new HttpServer(conf, outputDir, new SecurityManager(conf), classServerPort, "HTTP class server") var sparkContext: SparkContext = _ var sqlContext: SQLContext = _ var interp = new SparkILoop // this is a public var because tests reset it.