diff options
author | Thomas Graves <tgraves@apache.org> | 2014-01-04 11:42:17 -0600 |
---|---|---|
committer | Thomas Graves <tgraves@apache.org> | 2014-01-04 11:42:17 -0600 |
commit | ad35c1a5f2bbc44c077ccf1adb41910dc7ef0029 (patch) | |
tree | 19444b03a971f90753522b37603f7df145c41294 | |
parent | 10fe23bc34bcc8c25fb5440b71a6be883523e4dc (diff) | |
download | spark-ad35c1a5f2bbc44c077ccf1adb41910dc7ef0029.tar.gz spark-ad35c1a5f2bbc44c077ccf1adb41910dc7ef0029.tar.bz2 spark-ad35c1a5f2bbc44c077ccf1adb41910dc7ef0029.zip |
Fix handling of empty SPARK_EXAMPLES_JAR
-rw-r--r-- | core/src/main/scala/org/apache/spark/SparkConf.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/SparkConf.scala b/core/src/main/scala/org/apache/spark/SparkConf.scala index 98343e9532..7073a999a9 100644 --- a/core/src/main/scala/org/apache/spark/SparkConf.scala +++ b/core/src/main/scala/org/apache/spark/SparkConf.scala @@ -67,7 +67,7 @@ class SparkConf(loadDefaults: Boolean) extends Serializable with Cloneable { /** Set JAR files to distribute to the cluster. */ def setJars(jars: Seq[String]): SparkConf = { - set("spark.jars", jars.mkString(",")) + set("spark.jars", jars.filter(_ != null).mkString(",")) } /** Set JAR files to distribute to the cluster. (Java-friendly version.) */ |