diff options
Diffstat (limited to 'repl/src')
-rw-r--r-- | repl/src/main/scala/org/apache/spark/repl/ExecutorClassLoader.scala | 9 |
1 files changed, 5 insertions, 4 deletions
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 2f07395edf..df13b32451 100644 --- a/repl/src/main/scala/org/apache/spark/repl/ExecutorClassLoader.scala +++ b/repl/src/main/scala/org/apache/spark/repl/ExecutorClassLoader.scala @@ -17,7 +17,7 @@ package org.apache.spark.repl -import java.io.{ByteArrayOutputStream, FilterInputStream, InputStream, IOException} +import java.io.{ByteArrayOutputStream, FileNotFoundException, FilterInputStream, InputStream, IOException} import java.net.{HttpURLConnection, URI, URL, URLEncoder} import java.nio.channels.Channels @@ -147,10 +147,11 @@ class ExecutorClassLoader( private def getClassFileInputStreamFromFileSystem(fileSystem: FileSystem)( pathInDirectory: String): InputStream = { val path = new Path(directory, pathInDirectory) - if (fileSystem.exists(path)) { + try { fileSystem.open(path) - } else { - throw new ClassNotFoundException(s"Class file not found at path $path") + } catch { + case _: FileNotFoundException => + throw new ClassNotFoundException(s"Class file not found at path $path") } } |