Skip to content

Commit

Permalink
Update SparkContext.scala
Browse files Browse the repository at this point in the history
  • Loading branch information
pzzs committed Mar 13, 2015
1 parent 0ff3fa8 commit d594e16
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion core/src/main/scala/org/apache/spark/SparkContext.scala
Original file line number Diff line number Diff line change
Expand Up @@ -1093,7 +1093,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli
def addFile(path: String, recursive: Boolean): Unit = {
val uri = new URI(path)
val schemeCorrectedPath = uri.getScheme match {
case null | "local" => "file:" + new File(path).getCanonicalPath
case null | "local" => new File(path).getCanonicalFile.toURI.toString
case _ => path
}

Expand Down

0 comments on commit d594e16

Please sign in to comment.