Fix handling of empty SPARK_EXAMPLES_JAR

This commit is contained in:
Thomas Graves 2014-01-04 11:42:17 -06:00
parent 10fe23bc34
commit ad35c1a5f2

View file

@ -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.) */