Skip to content

Commit acfbd8a

Browse files
committed
Change path to uri.toString.
1 parent fa82b3a commit acfbd8a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/main/scala/org/apache/spark/SparkContext.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1457,8 +1457,8 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli
14571457
logInfo(s"Added file $path at $key with timestamp $timestamp")
14581458
// Fetch the file locally so that closures which are run on the driver can still use the
14591459
// SparkFiles API to access files.
1460-
Utils.fetchFile(path, new File(SparkFiles.getRootDirectory()), conf, env.securityManager,
1461-
hadoopConfiguration, timestamp, useCache = false)
1460+
Utils.fetchFile(uri.toString, new File(SparkFiles.getRootDirectory()), conf,
1461+
env.securityManager, hadoopConfiguration, timestamp, useCache = false)
14621462
postEnvironmentUpdate()
14631463
}
14641464
}

0 commit comments

Comments
 (0)