Skip to content
Snippets Groups Projects
Commit f3679fd4 authored by Evan Chan's avatar Evan Chan
Browse files

Add local: URI support to addFile as well

parent e54a37fe
No related branches found
No related tags found
No related merge requests found
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment