diff --git a/repl/src/main/scala/org/apache/spark/repl/ExecutorClassLoader.scala b/repl/src/main/scala/org/apache/spark/repl/ExecutorClassLoader.scala index 8cc85391eb6a..c0796cc158ba 100644 --- a/repl/src/main/scala/org/apache/spark/repl/ExecutorClassLoader.scala +++ b/repl/src/main/scala/org/apache/spark/repl/ExecutorClassLoader.scala @@ -55,13 +55,8 @@ class ExecutorClassLoader( parent: ClassLoader, userClassPathFirst: Boolean) extends ClassLoader(null) with Logging { val uri = new URI(classUri) - val directory = uri.getPath - val parentLoader = new ParentClassLoader(parent) - // Allows HTTP connect and read timeouts to be controlled for testing / debugging purposes - private[repl] var httpUrlConnectionTimeoutMillis: Int = -1 - private val fetchFn: (String) => InputStream = uri.getScheme() match { case "spark" => getClassFileInputStreamFromSparkRPC case _ => @@ -160,7 +155,7 @@ class ExecutorClassLoader( private def getClassFileInputStreamFromFileSystem(fileSystem: FileSystem)( pathInDirectory: String): InputStream = { - val path = new Path(directory, pathInDirectory) + val path = new Path(new Path(uri), pathInDirectory) try { fileSystem.open(path) } catch {