aboutsummaryrefslogtreecommitdiff
path: root/repl
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2013-06-22 17:44:04 -0700
committerMatei Zaharia <matei@eecs.berkeley.edu>2013-06-22 17:44:04 -0700
commit0e0f9d3069039f03bbf5eefe3b0637c89fddf0f1 (patch)
tree02ae022ec5a08fd40881b6a566e5e95a4b56c569 /repl
parentb5df1cd668e45fd0cc22c1666136d05548cae3e9 (diff)
downloadspark-0e0f9d3069039f03bbf5eefe3b0637c89fddf0f1.tar.gz
spark-0e0f9d3069039f03bbf5eefe3b0637c89fddf0f1.tar.bz2
spark-0e0f9d3069039f03bbf5eefe3b0637c89fddf0f1.zip
Fix search path for REPL class loader to really find added JARs
Diffstat (limited to 'repl')
-rw-r--r--repl/src/main/scala/spark/repl/SparkILoop.scala4
1 files changed, 3 insertions, 1 deletions
diff --git a/repl/src/main/scala/spark/repl/SparkILoop.scala b/repl/src/main/scala/spark/repl/SparkILoop.scala
index 86eed090d0..59f9d05683 100644
--- a/repl/src/main/scala/spark/repl/SparkILoop.scala
+++ b/repl/src/main/scala/spark/repl/SparkILoop.scala
@@ -838,7 +838,9 @@ class SparkILoop(in0: Option[BufferedReader], val out: PrintWriter, val master:
if (prop != null) prop else "local"
}
}
- val jars = Option(System.getenv("ADD_JARS")).map(_.split(',')).getOrElse(new Array[String](0))
+ val jars = Option(System.getenv("ADD_JARS")).map(_.split(','))
+ .getOrElse(new Array[String](0))
+ .map(new java.io.File(_).getAbsolutePath)
sparkContext = new SparkContext(master, "Spark shell", System.getenv("SPARK_HOME"), jars)
sparkContext
}