diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2011-05-29 16:15:59 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2011-05-29 16:15:59 -0700 |
| commit | c501cff9243895bcbf7e5905965e22f05ba2132d (patch) | |
| tree | 7471f78558f018528ab8a965450ba537a74f1acf | |
| parent | 50ac1d2a40c0165c9b2cd0f1c3aff19a484bcd1a (diff) | |
| download | spark-c501cff9243895bcbf7e5905965e22f05ba2132d.tar.gz spark-c501cff9243895bcbf7e5905965e22f05ba2132d.tar.bz2 spark-c501cff9243895bcbf7e5905965e22f05ba2132d.zip | |
Executor was looking for the wrong constructor for ExecutorClassLoader
| -rw-r--r-- | core/src/main/scala/spark/Executor.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/Executor.scala b/core/src/main/scala/spark/Executor.scala index f32e66bef4..7764acad1a 100644 --- a/core/src/main/scala/spark/Executor.scala +++ b/core/src/main/scala/spark/Executor.scala @@ -108,7 +108,7 @@ class Executor extends mesos.Executor with Logging { loader = { try { val klass = Class.forName("spark.repl.ExecutorClassLoader").asInstanceOf[Class[_ <: ClassLoader]] - val constructor = klass.getConstructor(classUri.getClass, loader.getClass) + val constructor = klass.getConstructor(classOf[String], classOf[ClassLoader]) constructor.newInstance(classUri, loader) } catch { case _: ClassNotFoundException => loader |