diff options
author | Thomas Graves <tgraves@apache.org> | 2014-01-06 07:58:59 -0600 |
---|---|---|
committer | Thomas Graves <tgraves@apache.org> | 2014-01-06 07:58:59 -0600 |
commit | 25446dd931cce5916de5dddf4689b41ee6fd3148 (patch) | |
tree | 4d6353851cb58007daa9ed267f856c5dd09831bd /core | |
parent | ad35c1a5f2bbc44c077ccf1adb41910dc7ef0029 (diff) | |
download | spark-25446dd931cce5916de5dddf4689b41ee6fd3148.tar.gz spark-25446dd931cce5916de5dddf4689b41ee6fd3148.tar.bz2 spark-25446dd931cce5916de5dddf4689b41ee6fd3148.zip |
Add warning to null setJars check
Diffstat (limited to 'core')
-rw-r--r-- | core/src/main/scala/org/apache/spark/SparkConf.scala | 3 |
1 files changed, 2 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 7073a999a9..55f27033b5 100644 --- a/core/src/main/scala/org/apache/spark/SparkConf.scala +++ b/core/src/main/scala/org/apache/spark/SparkConf.scala @@ -24,7 +24,7 @@ import com.typesafe.config.ConfigFactory * * @param loadDefaults whether to load values from the system properties and classpath */ -class SparkConf(loadDefaults: Boolean) extends Serializable with Cloneable { +class SparkConf(loadDefaults: Boolean) extends Serializable with Cloneable with Logging { /** Create a SparkConf that loads defaults from system properties and the classpath */ def this() = this(true) @@ -67,6 +67,7 @@ class SparkConf(loadDefaults: Boolean) extends Serializable with Cloneable { /** Set JAR files to distribute to the cluster. */ def setJars(jars: Seq[String]): SparkConf = { + for (jar <- jars if (jar == null)) logWarning("null jar passed to SparkContext constructor") set("spark.jars", jars.filter(_ != null).mkString(",")) } |