diff options
| author | Evan Chan <ev@ooyala.com> | 2013-11-01 11:08:03 -0700 |
|---|---|---|
| committer | Evan Chan <ev@ooyala.com> | 2013-11-01 11:08:03 -0700 |
| commit | f3679fd494893d4feafec5c44d31adf1ee3aa2dc (patch) | |
| tree | 1e666ae4b51b1a7cceb0e6ccf3dfe278480c4086 /core | |
| parent | e54a37fe15a8fa8daec6c00fde4d191680b004c4 (diff) | |
| download | spark-f3679fd494893d4feafec5c44d31adf1ee3aa2dc.tar.gz spark-f3679fd494893d4feafec5c44d31adf1ee3aa2dc.tar.bz2 spark-f3679fd494893d4feafec5c44d31adf1ee3aa2dc.zip | |
Add local: URI support to addFile as well
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/SparkContext.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala index 8d7c5a77da..880b49e8ef 100644 --- a/core/src/main/scala/org/apache/spark/SparkContext.scala +++ b/core/src/main/scala/org/apache/spark/SparkContext.scala @@ -591,7 +591,8 @@ class SparkContext( val uri = new URI(path) val key = uri.getScheme match { case null | "file" => env.httpFileServer.addFile(new File(uri.getPath)) - case _ => path + case "local" => "file:" + uri.getPath + case _ => path } addedFiles(key) = System.currentTimeMillis |