Added SparkContext.addJar calls to support executing code on remote c…

…lusters
apache · Aug 27, 2014 · f420cbf · f420cbf
1 parent a826795
commit f420cbf
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/repl/src/main/scala/org/apache/spark/repl/SparkILoop.scala b/repl/src/main/scala/org/apache/spark/repl/SparkILoop.scala
@@ -715,6 +715,7 @@ class SparkILoop(in0: Option[BufferedReader], protected val out: JPrintWriter,
         addedClasspath = ClassPath.join(addedClasspath, f.path)
         totalClasspath = ClassPath.join(settings.classpath.value, addedClasspath)
         intp.addUrlsToClassPath(f.toURI.toURL)
+        sparkContext.addJar(f.toURI.toURL.getPath)
       }
     }
   }
@@ -724,6 +725,7 @@ class SparkILoop(in0: Option[BufferedReader], protected val out: JPrintWriter,
     if (f.exists) {
       addedClasspath = ClassPath.join(addedClasspath, f.path)
       intp.addUrlsToClassPath(f.toURI.toURL)
+      sparkContext.addJar(f.toURI.toURL.getPath)
       echo("Added '%s'.  Your new classpath is:\n\"%s\"".format(f.path, intp.global.classPath.asClasspathString))
     }
     else echo("The path '" + f + "' doesn't seem to exist.")