ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Format cleanup.

Browse source
This commit is contained in:
Benjamin Hindman 2013-07-30 17:01:00 -07:00
parent f6f46455eb
commit 7bdafa918a
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
repl/src/main/scala/spark/repl/SparkILoop.scala
View file

@ -832,7 +832,9 @@ class SparkILoop(in0: Option[BufferedReader], val out: PrintWriter, val master:
def createSparkContext(): SparkContext = { def createSparkContext(): SparkContext = {
val uri = System.getenv("SPARK_EXECUTOR_URI") val uri = System.getenv("SPARK_EXECUTOR_URI")
if (uri != null) System.setProperty("spark.executor.uri", uri) if (uri != null) {
System.setProperty("spark.executor.uri", uri)
}
val master = this.master match { val master = this.master match {
case Some(m) => m case Some(m) => m
case None => { case None => {