diff options
| author | Mridul Muralidharan <mridul@gmail.com> | 2013-05-16 17:49:14 +0530 |
|---|---|---|
| committer | Mridul Muralidharan <mridul@gmail.com> | 2013-05-16 17:49:14 +0530 |
| commit | feddd2530ddfac7a01b03c9113b29945ec0e9a82 (patch) | |
| tree | 35096f4fa1a76ca5b9d8073b43fef5fa32ee04e4 /core | |
| parent | 87540a7b386837d177a6d356ad1f5ef2c1ad6ea5 (diff) | |
| download | spark-feddd2530ddfac7a01b03c9113b29945ec0e9a82.tar.gz spark-feddd2530ddfac7a01b03c9113b29945ec0e9a82.tar.bz2 spark-feddd2530ddfac7a01b03c9113b29945ec0e9a82.zip | |
Filter out nulls - prevent NPE
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/SparkContext.scala | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/core/src/main/scala/spark/SparkContext.scala b/core/src/main/scala/spark/SparkContext.scala index 2ae4ad8659..15a75c7e93 100644 --- a/core/src/main/scala/spark/SparkContext.scala +++ b/core/src/main/scala/spark/SparkContext.scala @@ -537,6 +537,8 @@ class SparkContext( * filesystems), or an HTTP, HTTPS or FTP URI. */ def addJar(path: String) { + // weird - debug why this is happening. + if (null == path) return val uri = new URI(path) val key = uri.getScheme match { case null | "file" => env.httpFileServer.addJar(new File(uri.getPath)) |