diff --git a/core/src/main/scala/spark/MesosScheduler.scala b/core/src/main/scala/spark/MesosScheduler.scala index 6a592d13c3cc3f794fd98fad1978eaf6243b800c..1cfc7052c61ac2d0e791600f5f9b65e11bc3d9de 100644 --- a/core/src/main/scala/spark/MesosScheduler.scala +++ b/core/src/main/scala/spark/MesosScheduler.scala @@ -253,9 +253,11 @@ extends MScheduler with spark.Scheduler with Logging // Copy each JAR to a unique filename in the jarDir for ((path, index) <- sc.jars.zipWithIndex) { val file = new File(path) - val filename = index + "_" + file.getName - copyFile(file, new File(jarDir, filename)) - filenames += filename + if (file.exists) { + val filename = index + "_" + file.getName + copyFile(file, new File(jarDir, filename)) + filenames += filename + } } // Create the server jarServer = new HttpServer(jarDir)